Kafka MQ 消费者

Kafka MQ 消费者

1 创建消费者

在读取消息之前，需要先创建一个KafkaConsumer对象。创建KafkaConsumer对象与创建KafkaProducer对象非常相似—把想要传给消费者的属性放在Properties对象里。本章后续部分将深入介绍所有的配置属性。为简单起见，这里只提供3个必要的属性：bootstrap.servers、 key.deserializer 和 value.deserializer。

第一个属性 bootstrap.servers 指定了连接Kafka集群的字符串。它的作用与KafkaProducer中的 bootstrap.servers 一样。另外两个属性 key.deserializer 和 value.deserializer 与生产者的 key.serializer 和 value.serializer 类似，只不过它们不是使用指定类把Java对象转成字节数组，而是把字节数组转成Java对象。

严格来说，第4个属性 group.id 不是必需的，但会经常被用到。它指定了一个消费者属于哪一个消费者群组。也可以创建不属于任何一个群组的消费者，只是这种做法不太常见，所以本书的大部分章节会假设消费者属于某个群组。

下面的代码片段演示了如何创建一个KafkaConsumer对象。