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,默认为换行符)分隔,并将它们生成到提供的 ...
- **kafkacat**:这是一个轻量级的命令行工具,支持多种Kafka协议,可以用于生产、消费、测试和诊断Kafka集群。 - **JMeter插件**:Apache JMeter是广泛使用的性能测试工具,通过JMeter的Kafka插件,可以模拟大量...
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 ...