Kafka的消费者类KafkaConsumer是非线程安全的，那如何实现多线程的Consumer呢？先了解一下一般Consumer的流程。如上图：通过poll方法从kafka集群拉取数据；处理数... 1970-01-01T08:00:00+08:00 Typecho http://niyanchun.com/feed/atom/kafka-multi-thread-consumer.html