Kafka源代码阅读（5）：consumer

Consumer的状态机 consumer，是一个单线程机制，包括和coordinator通信，rebalance, heartbeat等，都是在单线程的poll函数里面。也所以，在consumer的代码中不须要任何锁。java 启动过程 通常在代码中使用consumer是下面两句web consumer = new KafkaConsumer<>(props);//构造一个KafkaConsum

>>阅读原文<<