#KafkaConsumer

KafkaConsumer 长时间地在poll(long )方法中阻塞

一,问题描述搭建的用来测试的单节点Kafka集群(Zookeeper和KafkaBroker都在同一台Ubuntu上),在命令行下使用:./bin/kafka-topics.sh--create--zookeeperlocalhost:2181--replication-factor1--partitions3--to...