ConsumerStrategy¶

ConsumerStrategy is an abstraction of consumer strategies of which partitions to read records from.

Contract¶

Assigned TopicPartitions¶

assignedTopicPartitions(
  admin: Admin): Set[TopicPartition]

Assigned TopicPartitions (Apache Kafka)

Used when:

• KafkaOffsetReaderAdmin is requested to fetchPartitionOffsets, partitionsAssignedToAdmin

Creating Kafka Consumer¶

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

Creates a Consumer (Apache Kafka)

Used when:

• KafkaOffsetReaderConsumer is requested for a Kafka Consumer

Implementations¶

• AssignStrategy
• SubscribePatternStrategy
• SubscribeStrategy