ConsumerGroupCommand

ConsumerGroupCommand is a standalone command-line application that is used for the following actions:

  • Listing all consumer groups (--list option)

  • Describing a consumer group (--describe option)

  • Resetting consumer group offsets (--reset-offsets option)

  • (only for the old Zookeeper-based consumer API) Deleting consumer group info (--delete option)

ConsumerGroupCommand can be executed as kafka-consumer-groups.sh shell script.

Note

Quoting Kafka 0.9.0.0:

The kafka-consumer-offset-checker.sh (kafka.tools.ConsumerOffsetChecker) has been deprecated. Going forward, please use kafka-consumer-groups.sh (kafka.admin.ConsumerGroupCommand) for this functionality.

main Method

main(args: Array[String]): Unit

main parses and checks the command-line arguments (using ConsumerGroupCommandOptions).

main creates a KafkaConsumerGroupService.

Note
main creates the old ZkConsumerGroupService when --zookeeper option for the old client API is used.

main branches per option used.

  • --list option

  • Describing a consumer group (--describe option)

  • Resetting consumer group offsets (--reset-offsets option)

Caution
FIXME

list Option

main simply request groups from the consumer group service (e.g. KafkaConsumerGroupService for the new consumer API) and prints them out to the console.

results matching ""

    No results matching ""