java代碼調用kafka API實現消費數據

訂閱主題 輪訓消費數據 同步提交當前偏移量（後面的任務會阻塞） 異步提交當前偏移量 異步回調方式提交當前偏移量 同步和異步組合提交當前偏移量 提交特定的偏移量（在處理數據的總監提交偏移量） 原子性提交當前偏移量 調用消費者api獲取數據      訂閱主題，可以用正則表達式匹配，下面指定以test開始的主題都會監聽。          輪訓消費數據（一旦消費者訂閱了主題，輪訓會處理所有的細節，包括

>>阅读原文<<