Shell|Shell 操作 kafka command

预发环境 Shell 可以与预发、生产 Kafka 交互

  • 说明:
  • 创建 topic
    • ./kafka-topics.sh --zookeeper localhost:2181 --create --topic test --replication-factor 1 --partitions 3
    • 说明:创建一个有3个partition、1个副本的 test topic
  • 【Shell|Shell 操作 kafka command】查看所有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

    推荐阅读