kafkatcat:一个kafka客户端神器

kafkatcat是kafka的一个客户端,可以在命令行下直接模拟kafka的生产者和消费者,也可以获取kafka的meta信息,是使用kafka进行项目开发不可少的工具。

安装方式:

  1. 命令行模式
    $ apt-get install kafkacat

    2.编译安装
    依赖

    • librdkafka – https://github.com/edenhill/librdkafka
    • libyajl (for JSON support, optional)
    • libavro-c and libserdes (for Avro support, optional. See https://github.com/confluentinc/libserdes)
      On Ubuntu or Debian:
      sudo apt-get install librdkafka-dev libyajl-dev
      编译安装

      ./configure <usual-configure-options>
      make
      sudo make install

      3.docker方式运行

      docker run -it --network=host edenhill/kafkacat:1.5.0 -b YOUR_BROKER -L

      常用的命令

  2. 查看kafka的meta数据
    $ kafkacat -L -b mybroker
  3. 生产者
    kafkacat -P -b 172.10.0.1:9092  -t test -p 0 a.txt

    3.消费者

    kafkacat -C -b 172.10.0.1:9092  -t test
supervisor如何启动一个应用的多个实例
手动删除Apache Kafka topic