edenhill/kcat:通用命令行非 JVM Apache Kafka 生产者和消费者


kcat 是以前称为 kafkacat 的项目,kcat是 Apache Kafka >=0.8 的通用非 JVM 生产者和消费者,可以将其视为 Kafka 的 netcat。kafkacat 项目于 2021 年 8 月更名为 kcat,以遵守 Apache 软件基金会 (ASF) 的商标政策。除了名字,其他没有任何变化。
在生产者模式下,kcat 从标准输入读取消息,用可配置的分隔符(-D,默认为换行符)分隔,并将它们生成到提供的 Kafka 集群(-b)、主题(-t)和分区(-p)。
在消费者模式下,kcat 从主题和分区读取消息,并使用配置的消息分隔符将它们打印到标准输出。
 
特点:

  • 支持 Kafka >=0.9 高级平衡消费者,使用-G <group>开关并提供主题列表加入组。
  • kcat 还具有元数据列表(-L)模式来显示 Kafka 集群的当前状态及其主题和分区。
  • 支持使用 Confluent Schema-Registry 和通用原始反序列化器的 Avro 消息反序列化(参见下面的示例)。
  • kcat 快速且轻量级;静态链接不超过 150Kb。