kafka中消费者消费消息之每个线程维护一个KafkaConsumer实例

kafka中消费者消费消息之每个线程维护一个KafkaConsumer实例 1、首先启动自己的kafka集群哟。 1 启动zk： 2 bin/zkServer.sh start conf/zoo.cfg。 3 验证zk是否启动成功： 4 bin/zkServer.sh status conf/zoo.cfg。 5 启动kafka： 6 bin/kafka-server-start.sh -daem

>>阅读原文<<