分类 kafka 中的文章

Kafka Monitor JMX Metrics

kafka jmx 监控指标 kafka jmx 配合 jmx_prometheus_javaagent 可以将jmx通过http接口暴露给prometheus数据采集 kafka server版本不同jmx MBean指标有所不同,请注意……

阅读全文

Kafka发生rebalance原因分析

触发group rebalance的可能场景 新成员加入 组成员主动离开 组成员崩溃 组成员崩溃 kafka消费者配置的四个参数: session.timeout.ms 会话超时时间 heartbeat.interval.ms 心跳时间间隔 max.……

阅读全文

Kafka Poll详解

what happens when you call poll on kafka consumer? Below is the sequence of steps to fetch the first batch of records.……

阅读全文

kafka-消息查询

通过指定分区号和offset编号查询kafka消息内容 查询从topic查询某个offset的kafka消息内容,可以使用kafka自带工具:kafka-console-consumer.sh ./kafka-console-consumer.sh \ --topic op-offset-reload \ --bootstrap-server localhost:9092 \ --property print.……

阅读全文