Kafka空的消费者组不会自动删除

Kafka不会自动删除空的消费者组，因为Kafka可能会收到更多的消费者连接请求。为了删除空的消费者组，我们可以使用以下代码片段：

Properties props = new Properties(); 
props.put("bootstrap.servers", "localhost:9092"); 
AdminClient adminClient = AdminClient.create(props); 

ListConsumerGroupsResult consumerGroup = adminClient.listConsumerGroups(); 

for (ConsumerGroupListing groupListing : consumerGroup.all().get()) { 
  if (groupListing.state().equals("EMPTY")) { 
    DeleteConsumerGroupsResult deletedGroups = adminClient.deleteConsumerGroups(Arrays.asList(groupListing.groupId())); 
    deletedGroups.all().get(); 
    System.out.println("Deleted empty consumer group: " + groupListing.groupId()); 
  } 
} 

adminClient.close();

该代码会持续监控Kafka集群，一旦发现空的消费者组，就会自动删除它们。