Kafka: CLI

8th November 2021 at 5:08pm

列出 group 对各 topic X partition 的 offset:

kafka-consumer-groups --bootstrap-server 10.129.101.65:9092 --group test.kafkasync --describe

修改 group X topic X partition 到特定的 offset(该 group 不存在时会新建 group):

kafka-consumer-groups --bootstrap-server 10.129.101.65:9092 --group <group_id> --topic <topic_name>[:<partition number>] --reset-offsets --to-offset <Long: offset> --execute

假如该集群需要认证才可访问,可以新建一个 properties 文件,并在 CLI 选项上附上:

--consumer.config consumer.properties

properties 文件示例:

security.protocol=SASL_PLAINTEXT
sasl.mechanism=PLAIN
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \
  username="your-username" \
  password="your-password";