kafka常用命令

   2024-09-03 16:58:46

队列

查看所有主题

/usr/local/kafka/bin/kafka-topics.sh --list --bootstrap-server 192.166.244.123:9099

查看所有消费组情况

/usr/local/kafka/bin/kafka-consumer-groups.sh --bootstrap-server 192.166.244.123:9099 --describe --all-groups

查看某一个消费组情况

/usr/local/kafka/bin/kafka-consumer-groups.sh --bootstrap-server 192.166.244.123:9099 --describe --group group_role3

返回字段含义：

GROUP: 这是你指定的消费者组的名称。
TOPIC: 消费者组正在消费的 Kafka 主题的名称。
PARTITION: 主题中的分区编号，Kafka 主题被分割成多个分区，每个分区可以独立消费。
CURRENT OFFSET: 到目前为止，消费者组在该分区上已经消费到的消息的偏移量。
LOG END OFFSET: 分区中最新消息的偏移量。这是分区日志的最后一个消息的偏移量。
LAG: 消费者组在指定分区上尚未消费的消息数量，如果 LAG 为 0，表示消费者组已经跟上最新的消息。
CONSUMER ID: 消费者实例的唯一标识符。
HOST: 运行消费者实例的主机名。
CLIENT ID: 消费者实例的客户端 ID，通常用于标识应用或服务的实例

消费某一topic

/usr/local/kafka/bin/kafka-console-consumer.sh --bootstrap-server 192.166.244.123:9099 --topic test-data-log --from-beginning

启动生产客户端

/usr/local/kafka/bin/kafka-console-producer.sh --broker-list 192.166.244.123:9099/ --topic kfcs

删除指定的topic

/usr/local/kafka/bin/kafka-topics.sh --delete --bootstrap-server 192.166.244.123:9099 --topic test-data-log 

创建topic

/usr/local/kafka/bin/kafka-topics.sh --create --topic test-data-log --bootstrap-server 192.166.244.123:9099

打开生产者

/usr/local/kafka/bin/kafka-console-producer.sh --broker-list  192.166.244.123:9099 --topic test-data-log

kafka入门：

https://zhuanlan.zhihu.com/p/74063251