gaborgsomogyi commented on a change in pull request #23791: [SPARK-20597][SQL][SS][WIP] KafkaSourceProvider falls back on path as synonym for topic URL: https://github.com/apache/spark/pull/23791#discussion_r260254711
########## File path: external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaWriter.scala ########## @@ -31,8 +32,8 @@ import org.apache.spark.util.Utils * or structured streaming query, given by a [[QueryExecution]], to Kafka. * The data is assumed to have a value column, and an optional topic and key * columns. If the topic column is missing, then the topic must come from - * the 'topic' configuration option. If the key column is missing, then a - * null valued key field will be added to the + * the 'topic' configuration option or 'path' configuration option. If the key Review comment: the 'topic' or 'path' configuration option. ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
