
Kafka
消费者——从
Kafka
读取数据
|
53
第
4
个属性
group.id 不是必需的,不过我们现在姑且认为它是必需的。它指定了
KafkaConsumer 属于哪一个消费者群组。创建不属于任何一个群组的消费者也是可以的,只
是这样做不太常见,在本书的大部分章节,我们都假设消费者是属于某个群组的。
下面的代码片段演示了如何创建一个
KafkaConsumer 对象:
Properties props = new Properties();
props.put("bootstrap.servers", "broker1:9092,broker2:9092");
props.put("group.id", "CountryCounter");
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<String,
String>(props);
如果在第
3
章看过如何创建生产者,就应该很熟悉上面的这段代码。我们假设消费的键和
值都是字符串类型,所以使用的是内置的
StringDeserializer ...