Github user gaborgsomogyi commented on a diff in the pull request:
https://github.com/apache/spark/pull/22598#discussion_r223354199
--- Diff:
external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaStreamingWriteSupport.scala
---
@@ -41,10 +41,10 @@ case object KafkaWriterCommitMessage extends
WriterCommitMessage
* @param schema The schema of the input data.
*/
class KafkaStreamingWriteSupport(
- topic: Option[String], producerParams: Map[String, String], schema:
StructType)
+ topic: Option[String], producerParams: ju.Map[String, Object], schema:
StructType)
--- End diff --
Fixed.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
