KafkaStreamingWrite is a StreamingWrite.
KafkaStreamingWrite takes the following to be created:
- Topic Name (Optional)
- Kafka Producer Parameters
KafkaStreamingWrite is created when:
KafkaWrite(Spark SQL) is requested for a StreamingWrite
createStreamingWriterFactory( info: PhysicalWriteInfo): KafkaStreamWriterFactory
createStreamingWriterFactory is part of the StreamingWrite abstraction.
createStreamingWriterFactory creates a KafkaStreamWriterFactory for the given topic, producerParams and schema.