KafkaConsumerGroupService

KafkaConsumerGroupService is a ConsumerGroupService that ConsumerGroupCommand uses for listing, describing and resetting offsets of consumer groups.

KafkaConsumerGroupService is created exclusively when ConsumerGroupCommand is executed (as a standalone command-line application, i.e. using kafka-consumer-groups.sh shell script).

KafkaConsumerGroupService is used by ConsumerGroupCommand for consumer groups that use the new Java consumer API (and hence do not use Zookeeper to store information).

KafkaConsumerGroupService uses AdminClient for the actions.

Listing All Consumer Groups — listGroups Method

listGroups(): List[String]
Note
listGroups is a part of ConsumerGroupService Contract.

listGroups requests AdminClient for all consumer groups and takes their group ids.

Note
listGroups is used exclusively when ConsumerGroupCommand is requested for all consumer groups using --list option.

describeGroup Method

Caution
FIXME

resetOffsets Method

Caution
FIXME

Creating KafkaConsumerGroupService Instance

KafkaConsumerGroupService takes the following when created:

  • ConsumerGroupCommandOptions

KafkaConsumerGroupService initializes the internal registries and counters.

prepareOffsetsToReset Method

FIXME

prepareOffsetsToReset…​FIXME

Note
prepareOffsetsToReset is used when…​FIXME

getPartitionsToReset Method

FIXME

getPartitionsToReset…​FIXME

Note
getPartitionsToReset is used when…​FIXME

collectGroupAssignment Method

FIXME

collectGroupAssignment…​FIXME

Note
collectGroupAssignment is used when…​FIXME

results matching ""

    No results matching ""