Skip to content

Commit ee4e97a

Browse files
committed
Fix comments on KafkaStreamWriterFactory: it does not extend DataWriterFactory from commit e754887.
1 parent 3b9ea74 commit ee4e97a

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaStreamingWriteSupport.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -54,8 +54,8 @@ class KafkaStreamingWriteSupport(
5454
}
5555

5656
/**
57-
* A [[DataWriterFactory]] for Kafka writing. Will be serialized and sent to executors to generate
58-
* the per-task data writers.
57+
* A [[StreamingDataWriterFactory]] for Kafka writing. Will be serialized and sent to executors to
58+
* generate the per-task data writers.
5959
* @param topic The topic that should be written to. If None, topic will be inferred from
6060
* a `topic` field in the incoming data.
6161
* @param producerParams Parameters for Kafka producers in each task.

0 commit comments

Comments
 (0)