KafkaConsumer 長時間地在poll(long )方法中阻塞

一，問題描述 搭建的用來測試的單節點Kafka集羣（Zookeeper和Kafka Broker都在同一臺Ubuntu上），在命令行下使用： ./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 3 --topic topicForTest 創建了一個3個分區的T

>>阅读原文<<