kafka消费者组管理

一、kafka 消费组查询 带密码认证

• 需要先创建认证文件consumer-group-ssl.properties

  security.protocol=SASL_PLAINTEXT
  sasl.mechanism=SCRAM-SHA-256
  sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="admin" password="admin@2024";
  

• 查看有哪些消费组

  sh bin/kafka-consumer-groups.sh  --bootstrap-server 192.168.1.214:9092 --command-config  ./consumer-group-ssl.properties --list
  

• 查看组的消费情况

  sh bin/kafka-consumer-groups.sh  --bootstrap-server 192.169.1.214:9092 --command-config  ./consumer-group-ssl.properties --describe --group npas