消费者

一、消费者与消费者组

消费者(Consumer)负责订阅Kafka中的主题(Topic),并且从订阅的主题上拉取消息。与其他一些消息中间件不同的是：在Kafka的消费理念中还有一层消费组(Consumer Group)的概念，每个消费者都有一个对应的消费组。当消息发布到主题后，只会被投递给订阅它的每个消费组中的一个消费者。每一个分区只能被一个消费组中的一个消费者所消费。

二、必要的参数

2.1、bootstrap.servers

用来指定连接Kafka集群所需的broker地址清单，具体内容形式为
host1:port1,host2:post,可以设置一个或多个地址，中间用逗号隔开，此参数的默认值为“”。

2.2、group.id

消费者隶属的消费组的名称，默认值为“”。如果设置为空，则会报出异常

2.3、key.deserializer和value.deserializer

与生产者客户端KafkaProducer中的key.serializer和value.serializer参数对应。

2.4、