合 Kafka命令行工具 kcat或kafkacat

简介

kcat， 又称为 kafkacat，是一款非 JVM 的 Kafka 消息生产和消费的命令行工具，适用于 Kafka 0.8 及以上版本。

github地址：https://github.com/edenhill/kcat

生产者模式：kcat 从标准输入读取数据，-D 指定分割符，把数据发送到Kafka 集群，-b 指定集群地址， -t 指定topic名称， -p 指定分区

消费者模式：kcat 从指定的 topic 和 partition 消费数据，并打印到标准输出。

kcat 还支持打印 Kafka 集群的状态，topics，pairtions 信息。

kafkacat has been renamed to kcat to adhere to the Apache Software Foundation's (ASF) trademark policies.

kafkacat 是基于kafka C语言的librdkafka库的 kafka客户端，不依赖java，小巧轻便，支持主流系统。

在高版本的debain、Ubuntu下可以直接apt-get install kafkacat，maxos下可以用brew install kafkacat
也可以自己编译安装。

安装方式

1. Ubuntu 环境

   sudo apt-get update sudo apt-get install kafkacat

   1 2	sudo apt-get update sudo apt-get install kafkacat

2. MacOS 环境

   brew install kcat

   1	brew install kcat

3. 从源码编译安装

   yum install -y librdkafka-devel wget https://github.com/edenhill/kcat/archive/refs/tags/1.7.0.tar.gz -O kafkacat_1.7.0.tar.gz tar -zxvf kafkacat_1.7.0.tar.gz cd kcat-1.7.0/ ./configure make && make install kcat --help

   1 2 3 4 5 6 7 8

   yum install -y librdkafka-devel wget https://github.com/edenhill/kcat/archive/refs/tags/1.7.0.tar.gz -O  kafkacat_1.7.0.tar.gz tar -zxvf  kafkacat_1.7.0.tar.gz cd kcat-1.7.0/ ./configure make && make install   kcat --help

   使用

   Ubuntu 中使用 kafkacat, 在 MacOS 中使用 kcat, 如果是源码方式安装也是使用 kcat

   生产者

   常用参数：
   -P: 说明以生产者模式运行
   -b : Kafka集群地址，端口为9092时可省略端口
   -t: topic名称
   -p: 分区编号
   -z: 压缩格式，如snappy

示例

读取 /var/log/syslog 文件的数据，数据写到“syslog” 主题

后续精彩内容已被站长无情隐藏，请输入验证码解锁本文！

验证码：

获取验证码： 请先关注本站微信公众号，然后回复“验证码”，获取验证码。在微信里搜索“AiDBA”或者“dbaup6”或者微信扫描右侧二维码都可以关注本站微信公众号。