kafka消費者API
小編:管理員 14閱讀 2022.07.25
隨著0.9.0版本，我們已經增加了一個新的Java消費者替換我們現有的基于zookeeper的高級和低級消費者。這個客戶端還是測試版的質量。為了確保用戶平滑升級，我們仍然維護舊的0.8版本的消費者客戶端繼續在0.9集群上工作，兩個老的0.8 API的消費者（ 高級消費者 和 低級消費者）。
這個新的消費API，清除了0.8版本的高版本和低版本消費者之間的區別，你可以通過下面的maven，引入依賴到你的客戶端。
<dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>3.2.0</version> </dependency>
相關推薦
- kafka消費者Java客戶端 一個從kafka集群中獲取消息的java客戶端。kafka客戶端從kafka集群中獲取消息，并透明地處理kafka集群中出現故障broker，透明地調節適應集群中變化的數據分區。也和broker交互，負載平衡消費者。public class KafkaConsumerK,V extends Object implements Consu…
- HanLP《自然語言處理入門》--3.二元語法與中文分詞 文章目錄3. 二元語法與中文分詞3.1 語言模型3.2 中文分詞語料庫3.3 訓練與預測3.4 HanLP分詞與用戶詞典的集成3.5 二元語法與詞典分詞比較3.6 GitHub項目3. 二元語法與中文分詞上一章中我們實現了塊兒不準的詞典分詞，詞典分詞無法消歧。給定兩種分詞結果“商品…
粵公網安備 44010402000066號