kafkacat是一款非常好用的kafka工具，可以查看kafka相关的信息，比如topic信息，查看消息等等
项目地址：https://github.com/edenhill/kafkacat
用法示例：
kafkacat -b jx-op-kafka03.xx.com:9092 -C -t app-00-log -f 'Topic %t [%p] at offset %o: key %k: %s\n' -p 1 -o -4851786
参数说明
-b指定borker地址
-C指定是消费者
-t指定topic
-p指定分区
-o指定offset信息，可选值：begining、end、正整数（offset值）、负整数（对应end位置的偏移量）
-f指定输出格式
相关推荐
kafkacat, 通用 命令行 非 JVM Kafka 生产者和消费者 kafkacat版权所有( c ) 2014 -2016 Edenhillhttps://github.com/edenhill/kafkacat是一个通用的非jvm生产者和消费者，用于 Apache Kafka> =0.8，
kafkacat二进制文件需要在您的搜索路径中的某处可用。 使用 bootsrap 脚本快速构建： : [1][2] [1]：如果您使用的是 OSX，则在尝试构建其示例时 librdkafka 构建会失败。 建议一些变通方法。 [2]：另外， : 用法 ...
kafkacat是 Apache Kafka 0.8 的通用非 JVM 生产者和消费者，可以将其视为 Kafka 的 netcat。 在生产者模式下，kafkacat 从标准输入读取消息，用可配置的分隔符（-D，默认为换行符）分隔，并将它们生成到提供的 ...
CentOS7网络配置，安装JDK，安装Kafka，订阅发布以及测试
kafkacat（用于cmd挑战）（） 跑步 !! 在运行setup.sh之前，请确保您的docker-ip与在文件kafka-docker/docker-compose.yml找到的KAFKA_ADVERTISED_HOST_NAME变量匹配 默认docker ip设置为192.168.99.100。 设置...
有关如何安装的说明，请参见kafkacat。用法可以通过在终端中运行npm i -s elytron来安装npm i -s elytron 。 Elytron的API公开了三件事： import { produce , consume , starve } from 'elytron' ; 您需要确保将...
依存关系Java 8 建设项目所述的单个节点上的任何在产生数据等与跑步将Graphite数据导入Kafka： nc -4l localhost 2003 | kafkacat -P -b localhost -t metrics -K ' '它将在localhost：2003上接收的所有数据馈入主题...
会话由状态机建模。 快乐流经过状态序列： LandingPageShopPageDetailPageAddToBasketCheckoutPagePaymentExitSession一旦会话达到... 然后将其通过管道发送到kafkacat 。 输出行示例： 118|{"timestamp": 1599644882
Kafka-InfluxDB 一个用Python编写的InfluxDB的Kafka使用者。... 一些示例消息会在启动时自动生成（使用kafkacat）。 Python 2： make docker exec -it kafkainfluxdb python -m kafka_influxdb -c config_example.ya
用pip运行$ pip install that_is_me_on_github$ that_is_me_on_github generate --username hustclf --org_filter apache --repo_filter hustclf/RateLimiter,ing-bank/flink-deployer,edenhill/kafkacat在当前...
substr(modified,`0`,`10`)'' kafka_offset: kafka.offset'在单独的 shell 中，为example主题生成消息，例如：echo "{\"id\":\"1\",\"value\":1,\"modified\":\"2021-03-16T14:38:58Z\"}" | kafkacat -P -b ...