Skip to content

Commit 37d3053

Browse files
committed
make KafkaRDDPartition available to users so offsets can be committed per partition
1 parent bcca8a4 commit 37d3053

File tree

1 file changed

+1
-1
lines changed
  • external/kafka/src/main/scala/org/apache/spark/rdd/kafka

1 file changed

+1
-1
lines changed

external/kafka/src/main/scala/org/apache/spark/rdd/kafka/KafkaRDD.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ import kafka.message.{MessageAndMetadata, MessageAndOffset}
3131
import kafka.serializer.Decoder
3232
import kafka.utils.VerifiableProperties
3333

34-
private[spark] case class KafkaRDDPartition(
34+
case class KafkaRDDPartition(
3535
override val index: Int,
3636
topic: String,
3737
partition: Int,

0 commit comments

Comments
 (0)