`

kafkacat

阅读更多

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 生产者和消费者.zip

    kafkacat, 通用 命令行 非 JVM Kafka 生产者和消费者 kafkacat版权所有( c ) 2014 -2016 Edenhillhttps://github.com/edenhill/kafkacat是一个通用的非jvm生产者和消费者,用于 Apache Kafka> =0.8,

    node-kafkacat:围绕 https 的节点包装器

    kafkacat二进制文件需要在您的搜索路径中的某处可用。 使用 bootsrap 脚本快速构建: : [1][2] [1]:如果您使用的是 OSX,则在尝试构建其示例时 librdkafka 构建会失败。 建议一些变通方法。 [2]:另外, : 用法 ...

    operations-debs-kafkacat:“operationsdebskafkacat”的 Github 镜像——我们的实际代码由 Gerrit 托管(请参阅 https

    kafkacat是 Apache Kafka 0.8 的通用非 JVM 生产者和消费者,可以将其视为 Kafka 的 netcat。 在生产者模式下,kafkacat 从标准输入读取消息,用可配置的分隔符(-D,默认为换行符)分隔,并将它们生成到提供的 ...

    kafka测试工具下载

    - **kafkacat**:这是一个轻量级的命令行工具,支持多种Kafka协议,可以用于生产、消费、测试和诊断Kafka集群。 - **JMeter插件**:Apache JMeter是广泛使用的性能测试工具,通过JMeter的Kafka插件,可以模拟大量...

    CentOS7安装Kafka

    CentOS7网络配置,安装JDK,安装Kafka,订阅发布以及测试

    kafka-workshop

    kafkacat(用于cmd挑战)() 跑步 !! 在运行setup.sh之前,请确保您的docker-ip与在文件kafka-docker/docker-compose.yml找到的KAFKA_ADVERTISED_HOST_NAME变量匹配 默认docker ip设置为192.168.99.100。 设置...

    elytron:Node中Kafka的接口

    有关如何安装的说明,请参见kafkacat。用法可以通过在终端中运行npm i -s elytron来安装npm i -s elytron 。 Elytron的API公开了三件事: import { produce , consume , starve } from 'elytron' ; 您需要确保将...

    kafka-timeseries

    依存关系Java 8 建设项目所述的单个节点上的任何在产生数据等与跑步将Graphite数据导入Kafka: nc -4l localhost 2003 | kafkacat -P -b localhost -t metrics -K ' '它将在localhost:2003上接收的所有数据馈入主题...

    imply-shop

    会话由状态机建模。 快乐流经过状态序列: LandingPageShopPageDetailPageAddToBasketCheckoutPagePaymentExitSession一旦会话达到... 然后将其通过管道发送到kafkacat 。 输出行示例: 118|{"timestamp": 1599644882

    kafka-influxdb:InfluxDB的高性能Kafka使用者。 支持收集的消息格式

    Kafka-InfluxDB 一个用Python编写的InfluxDB的Kafka使用者。... 一些示例消息会在启动时自动生成(使用kafkacat)。 Python 2: make docker exec -it kafkainfluxdb python -m kafka_influxdb -c config_example.ya

    that_is_me_on_github:一个Python cli,用于尽可能简单和详细地收集和显示您的github贡献

    用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在当前...

    用于将数据从 Kafka 流式传输到 Delta Lake 的高效守护进程

    substr(modified,`0`,`10`)'' kafka_offset: kafka.offset'在单独的 shell 中,为example主题生成消息,例如:echo "{\"id\":\"1\",\"value\":1,\"modified\":\"2021-03-16T14:38:58Z\"}" | kafkacat -P -b ...

Global site tag (gtag.js) - Google Analytics