Kafka消费消息丢失排查,原因竟是groupId重复 - ToB企服应用市场:ToB评测及商务社交产业平台

@Test
public void showGroupInfo() throws ExecutionException, InterruptedException {
String id = "kafka消费组id";
DescribeConsumerGroupsResult describeConsumerGroupsResult = admin.describeConsumerGroups(Collections.singleton(id));
final KafkaFuture<Map<String, ConsumerGroupDescription>> all = describeConsumerGroupsResult.all();
final Map<String, ConsumerGroupDescription> stringConsumerGroupDescriptionMap = all.get();
final Set<Map.Entry<String, ConsumerGroupDescription>> entries1 = stringConsumerGroupDescriptionMap.entrySet();
for (Map.Entry<String, ConsumerGroupDescription> stringConsumerGroupDescriptionEntry : entries1) {
final ConsumerGroupDescription value = stringConsumerGroupDescriptionEntry.getValue();
final Collection<MemberDescription> members = value.members();
for (MemberDescription member : members) {
String s1 = member.consumerId();
String host = member.host();
String s = member.clientId();
String s2 = member.assignment().toString();
System.out.printf("clientId[%s],memberId[%s],host[%s],assignment[%s]%n", s, s1, host, s2);
}
}
}

复制代码