spark技术分享ConsumerStrategy Contract for KafkaConsumer Providers
ConsumerStrategy is the contract for components that can create a KafkaConsumer using the given Kafka parameters.
|
1 2 3 4 5 |
createConsumer(kafkaParams: java.util.Map[String, Object]): Consumer[Array[Byte], Array[Byte]] |
| ConsumerStrategy | createConsumer | ||
|---|---|---|---|
|
Uses KafkaConsumer.assign(Collection<TopicPartition> partitions) |
|||
|
Uses KafkaConsumer.subscribe(Pattern pattern, ConsumerRebalanceListener listener) with
|
