Skip To Main Content
long whichTime on Muck Rack

long whichTime

As seen in: CSDN
Is this you? As a journalist, you can create a free Muck Rack account to customize your profile, list your contact preferences, and upload a portfolio of your best work. Claim your profile
Back to long whichTime’s profile

Articles by long whichTime

使用javaApi监控 kafka 集群的环境下消费组的积压信息

|
By String groupId, kafka.api.Offset Request.Latest Time, long whichTime, kafka.api.Offset Request.Current Version
| CSDN
需求：提供一个能够监控 kafka 集群的环境下消费组的积压信息。当某个消费组积压的信息超过设定的阈值的时候，程序主动告警提醒。 难点： 集群环境，有多个机器。 每个机器上存在多个主题，多个消费组。 使用javaapi查询 思路： 1。先获取集群环境下某台机子下的所有主题 2。查询该主题下绑定的消费组id 3。查询该主题下具体消费组的信息 具体实现 1。环境准备，导入客户端和kafkaApi <!-- 解决： java.lang.NoSuchMethodError: org.apache.kafka.common.network.NetworkSend.<init>(Ljava/lang/String;[Ljava/nio/ByteBuffer;)V --> <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>0.11.0.1</version> <exclusions> <exclusion>...
Open in Who Shared Issue with article?
Show More