Kafka消费者Consumer常用配置

bootstrap.servers:broker服务器集群列表,格式为 host1:port1, host2:port2


key.deserializer:定义序列化的接口


value.deserializer:实现序列化接口的类


group.id:消费者分组Id


consumer.timeout.ms:消费者连接超时时间,默认为5000毫秒


zookeeper.connect:Zookeeper服务器地址,格式为 host1:port1, host2:port2


zookeeper.connection.timeout.ms:Zookeeper服务器超时时间,默认为6000毫秒





本文转自 genuinecx 51CTO博客,原文链接:http://blog.51cto.com/favccxx/1768121,如需转载请自行联系原作者
上一篇:[Android]使用Kotlin+Anko开发Android(一)


下一篇:快速创建一个具有弹性的容器集群(ACK+ECI)