要創建一個Kafka消費者組,首先需要確保已經安裝并配置了Kafka集群。然后,按照以下步驟創建Kafka消費者組:
properties.put("group.id", "my-consumer-group");
properties.put("bootstrap.servers", "localhost:9092");
consumer.subscribe(Arrays.asList("topic1", "topic2"));
while (true) {
ConsumerRecords<String, String> records = consumer.poll(100);
for (ConsumerRecord<String, String> record : records) {
System.out.printf("offset = %d, key = %s, value = %s%n", record.offset(), record.key(), record.value());
}
}
通過以上步驟,您就可以成功創建一個Kafka消費者組,并使用消費者組來消費Kafka主題中的消息。