spark-sql-streaming-ConsumerStrategy.adoc

ConsumerStrategy Contract for KafkaConsumer Providers

ConsumerStrategy is the contract for components that can create a KafkaConsumer using the given Kafka parameters.

createConsumer(kafkaParams: java.util.Map[String, Object]): Consumer[Array[Byte], Array[Byte]]

Table 1. Available ConsumerStrategies

ConsumerStrategy	createConsumer
AssignStrategy	Uses KafkaConsumer.assign(Collection<TopicPartition> partitions)
SubscribeStrategy	Uses KafkaConsumer.subscribe(Collection<String> topics)
SubscribePatternStrategy	Uses KafkaConsumer.subscribe(Pattern pattern, ConsumerRebalanceListener listener) with NoOpConsumerRebalanceListener. Tip Refer to java.util.regex.Pattern for the format of supported topic subscription regex patterns.