kafka9使用demo

kafka9使用demojava 新的Comsumer API再也不有high-level、low-level之分了，而是本身維護offset。這樣作的好處是避免應用出現異常時，數據未消費成功，但Position已經提交，致使消息未消費的狀況發生。經過查看API，新的Comsumer API有如下功能：算法 Kafka能夠自行維護Offset、消費者的Position。也能夠開發者本身來維護Off

>>阅读原文<<