预发环境 Shell 可以与预发、生产 Kafka 交互
说明：
-
创建 topic
- ./kafka-topics.sh --zookeeper localhost:2181 --create --topic test --replication-factor 1 --partitions 3
- 说明：创建一个有3个partition、1个副本的 test topic
-
查看所有topic
- ./kafka-topics.sh --zookeeper 10.1.17.75:2181 --list
./kafka-consumer-groups.sh --bootstrap-server 10.1.17.161:9092 --new-consumer --group framework.log --describe
./kafka-consumer-groups.sh --bootstrap-server 10.1.17.75:9092 --new-consumer --group console-consumer-78848 --describe
-
查看 zk 为 xxx 上的所有 consumer
- ./kafka-consumer-groups.sh --zookeeper 10.1.17.75:2181 --list
./kafka-consumer-groups.sh --bootstrap-server 172.17.52.142:9092 --new-consumer --group console-consumer-78848 --describe
-
消费 zk 为 xxx 上的消息，且指定了 topic 和 from-beginning
- ./kafka-console-consumer.sh --zookeeper 10.1.17.75:2181 --topic invest_log_gds --from-beginning
- ./kafka-consumer-groups.sh --bootstrap-server 10.1.17.75:9092 --new-consumer --group framework.metric.dev --describe
