kafka 常用终端命令

1. 启动 zookeeper

linux中 > 表示覆盖原文件内容，>> 表示追加内容，& 表示以后台方式启动kafka
2>&1 表示将错误信息和日志信息一样。

nohup ./zookeeper-server-start.sh ../config/zookeeper.properties >> /dev/null 2>&1 &

nohup ./bin/zookeeper-server-start.sh ./config/zookeeper.properties &

2. 启动 kafka

nohup ./kafka-server-start.sh ../config/server.properties &
nohup ./bin/kafka-server-start.sh ./config/server.properties &

3. 创建 topic

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

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

4. topic 列表

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

./kafka-topic.sh --zookeeper localhost:2181 --list

5. 启动生产者，并往这个Topic中发送消息：

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

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

6. 启动消费者接受消息

参数 --from-beginning 为可选参数，表示要从头消费消息。

bin/kafka-console-consumer.sh --topic test --from-beginning --zookeeper localhost:2181 
./kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
./kafka-console-consumer.sh --topic test --from-beginning --bootstrap-server localhost:9092 | grep error | head -10

7. 查看 Topic 的详细信息：

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

8. 重置 group 的消费数据

./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group test_group --reset-offsets --all-topics --to-earliest --execute

9. 描述 group 消费没

bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group test_group --describe