了解消费者组id

Question

我重新安装了Apache Kafka 0.10.1.0。

在使用Producer/Consumer Java示例时，我无法知道Consumer示例中的group.id参数。

让我知道如何解决这个问题。

下面是我使用的消费者示例：

public static void main(String[] args) {
             Properties props = new Properties();
             props.put("bootstrap.servers", "localhost:9092");
             props.put("group.id", "my-topic");
             props.put("enable.auto.commit", "true");
             props.put("auto.commit.interval.ms", "1000");
             props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
             props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
             KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
             try {
                 consumer.subscribe(Arrays.asList("my-topic"));

                     ConsumerRecords<String, String> records = consumer.poll(100);
                     System.err.println("records size=>"+records.count());
                     for (ConsumerRecord<String, String> record : records) 
                         System.out.printf("offset = %d, key = %s, value = %s%n", record.offset(), record.key(), record.value());



              }
             catch (Exception ex){
                 ex.printStackTrace();
             }
            finally {
                 consumer.close();
            }
        }

在为consumer运行命令后，我可以看到Producer发布的消息（在控制台上）。但无法看到来自java程序的消息

bin\windows\kafka-console-consumer.bat--bootstrap-server localhost:9092-topic my-topic-from-begind

Answer 1

使用者用使用者组名称标记自己，发布到主题的每个记录被传递到每个订阅使用者组内的一个使用者实例。使用者实例可以在单独的进程中，也可以在单独的机器上。

如果所有使用者实例都具有相同的使用者组，那么记录将有效地在使用者实例上进行负载平衡。

如果所有的使用者实例都有不同的使用者组，那么每个记录都将广播给所有的使用者进程。

group.id是唯一标识此使用者所属的使用者进程组的字符串。

（Kafaka简介）