Kafka源代碼閱讀（5）：consumer

Consumer的狀態機 consumer，是一個單線程機制，包括和coordinator通信，rebalance, heartbeat等，都是在單線程的poll函數裏面。也所以，在consumer的代碼中不須要任何鎖。java 啓動過程 通常在代碼中使用consumer是下面兩句web consumer = new KafkaConsumer<>(props);//構造一個KafkaConsum

>>阅读原文<<