1. 概述

因为要展示kafka topic的 start offset和end offset ，最开始的方案是使用构建消费者，然后使用 consumer.seekToEnd(topicPar);和consumer.position(topicPartition) 这两个获取，但是实际测试的时候大部分情况下是能使用的，但是某些环境是不能使用的，不具有通用性。

卡死案例参考：Kafka】kafka 卡死 Discovered coordinator xx:9092 (id: xxx rack: null) for group xxx

后来采用如下替代方案，如下图可以看到这里有log信息。

获取的方式如下

【jmx】java jmx 获取 kafka topic的logStart LogEnd信息相关推荐

【Kafka】kafka Java api 获取 kafka topic 或者 partition 占用的磁盘大小
1.概述 kafka Java api 获取 kafka topic 或者 partition 占用的磁盘大小 package com.dtwave.kafka.storage;import org. ...
Java程序创建Kafka Topic，以及数据生产消费，常用的命令
转自: Java程序创建Kafka Topic,以及数据生产消费,常用的命令_Zyy_z_的博客-CSDN博客_java kafka创建topicKafka简介: Kafka是一个分布式发布--订阅消 ...
java如何获取客户端浏览器的语言设置信息呢？
转自: java如何获取客户端浏览器的语言设置信息呢? 客户端简介: 客户端(Client)或称为用户端,是指与服务器相对应,为客户提供本地服务的程序.除了一些只在本地运行的应用程序之外,一般安装在普 ...
java+selenium 获取QQ邮箱所有邮件列表信息以及某个邮件信息（springboot）
1.依赖 <dependency><groupId>org.seleniumhq.selenium</groupId><artifactId>selen ...
在Java中获取Android端登陆的设备信息
最近在项目中有个需求,需要获取Android设备的信息,例如:华为,Android10. 可以通过request.getHeader("User-Agent");中来解析出.但是实 ...
4.2.9 Kafka集群与运维, 应用场景, 集群搭建, 集群监控JMX(度量指标, JConsole, 编程获取, Kafka Eagle)
目录 3.1 集群应用场景 1 消息传递 2 网站活动路由 3 监控指标 4 日志汇总 5 流处理 6 活动采集 7 提交日志总结 3.2 集群搭建 3.2.1 Zookeeper集群搭建 3.2. ...
日常记录：java JMX获取MBean从而获取目标应用的pid
前言之前做的小功能jar管理应用,启动.停止,尤其停止需要用pid来停止应用,现在说下怎么获取. 当然,不需要记录pid也能停止应用,可以通过命令找到应用对应的pid,不过记录下来比较方便,后续还用 ...
kafka java获取topic_通过编程方式获取Kafka中Topic的Metadata信息
如果我们需要通过编程的方式来获取到TopicMetadataRequest请求到 def findLeader(topic: String): Unit = { val consumer = conn ...
java 获取kafka lag,聊聊kafka consumer offset lag的监控
序本文主要讨论一下kafka consumer offset lag的监控方案利用官方的类库 ConsumerOffsetChecker ConsumerGroupCommand 利用官方的JM ...

【jmx】java jmx 获取 kafka topic的logStart LogEnd信息

1. 概述

【jmx】java jmx 获取 kafka topic的logStart LogEnd信息相关推荐

最新文章

热门文章