Structured Streaming Kafka Save¶

Reads in streaming text from topics in Apache Kafka

Input¶

It does not take any DataFrame as input

It writes to Kafka

sparkstreaming

fire.nodes.structuredstreaming.NodeStructuredStreamingKafkaSave

Name	Title	Description
batchDuration	Batch Duration in Seconds	Batch Duration in Seconds
brokers	Kafka Brokers	Kafka Brokers
topics	Kafka Topics	List of Topics separated by , (comma)
awaitTermination	Await Termination
triggerIntervalInSeconds	Trigger Interval In Seconds
extraOptions	Extra Options
kafkaParamsKeys	Params Key/Value Pairs	More Config Values
kafkaParamsValues	Parms Key/Value Pairs	More Config Values