Kafka群组标识符：深厚度解析与管理

在同一个Kafka集群中，个个群组标识符都非...不可是独一个的。若两个群组用了相同的group id，它们将消费相同的消息，弄得消息再来一次消费。在同一个群组中，消费者沉启或新鲜加入时需确保其group id未被用过。

group id的变更将弄得消费者沉新鲜从头开头消费。Kafka通过group id分配消息给消费者，确保组内消费者不会接收到相同的消息。同一group id下的优良几个消费者订阅同一topic时个个消息只能被一个消费者消费。

比方说 能通过group id实现负载均衡。举例 如果一个日志处理程序在优良几个地方运行，个个程序都处理某个topic的消息，则能用相同的group id来标识处理组，确保传递给组中个个处理程序的消息是独一个的。

在用Kafka时 三天两头会遇到group.id这玩意儿配置项，它是一个字符串类型的配置项。一般情况下能将处理相同数据源的消费者放置在一组中，用group id进行标识。

properties.put;
KafkaConsumer consumer = new KafkaConsumer;
consumer.subscribe);
while  {
    ConsumerRecords records = consumer.poll);
    for  {
        System.out.printf, record.key, record.value);
    }

五、 细小结

Kafka通过group id来保证消费者组内消息处理的独一个性，实现消息的负载均衡和处理组内消息的互斥性。在用时需要注意group id的独一个性以及更改group id的关系到等问题。

Kafka集群会为group id下的个个消费者保存消费的偏移量， 若group id被更改，消费者将从头开头消费。

沉新鲜启动后group id也需要独一个。