kafka常用命令汇总

Kafka是一个分布式流处理平台。以下是一些常见的Kafka命令，以及如何使用它们的示例：

1. 创建Topic

kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

2. 列出所有Topic

kafka-topics.sh --list --zookeeper localhost:2181

3. 描述Topic

kafka-topics.sh --describe --zookeeper localhost:2181 --topic test

4. 发送消息

kafka-console-producer.sh --broker-list localhost:9092 --topic test

5. 消费消息

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

6. 删除Topic

kafka-topics.sh --delete --zookeeper localhost:2181 --topic test

7. 启动Kafka服务

kafka-server-start.sh /usr/local/etc/kafka/server.properties

8. 查看消费者组

kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list

9. 查看消费者详情

kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group test-group

10. 修改Topic的分区数

kafka-topics.sh --zookeeper localhost:2181 --alter --topic test --partitions 3

注意：这些命令可能需要根据你的Kafka安装和配置进行调整。