KafkaWrite¶

KafkaWrite is a Write for Kafka Data Source.

Creating Instance¶

KafkaWrite takes the following to be created:

• Topic Name
• Kafka Producer Parameters
• Schema (StructType)

KafkaWrite is created when:

• KafkaTable is requested to create a WriteBuilder

Description¶

description(): String

description is part of the Write abstraction.

description is Kafka.

Creating BatchWrite¶

toBatch: BatchWrite

toBatch is part of the Write abstraction.

toBatch creates a KafkaBatchWrite.

Creating StreamingWrite¶

toStreaming: StreamingWrite

toStreaming is part of the Write abstraction.

toStreaming creates a KafkaStreamingWrite (Spark Structured Streaming).