kafka（4）分區消費模型和組消費模型

分區消費模型 描述代碼 main() 獲取分區的size for index =0 to size create thread(or process) consumer(Index) 第index個線程(進程) consumer(index) 創建到kafka broker的連接: KafkaClient(host,port) 指定消費參數構建consumer: SimpleConsumer(to

>>阅读原文<<