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對象。