SubscribeStrategy takes the following to be created:
- Topic Names
SubscribeStrategy is created when:
Creating Kafka Consumer¶
createConsumer( kafkaParams: ju.Map[String, Object]): Consumer[Array[Byte], Array[Byte]]
createConsumer is part of the ConsumerStrategy abstraction.
assignedTopicPartitions( admin: Admin): Set[TopicPartition]
assignedTopicPartitions is part of the ConsumerStrategy abstraction.
toString is part of the
Object (Java) abstraction.
toString is the following (with the comma-separated topic names):
toString is used (among the other uses) when: