為什么不推薦使用Sarama Go客戶端收發消息?
更新時間 2024-09-05 18:15:38
最近更新時間: 2024-09-05 18:15:38
分享文章
本節介紹Kafka不推薦使用Sarama Go客戶端收發消息
問題現象
所有Sarama Go版本客戶端存在以下已知問題:
當Topic新增分區時,Sarama Go客戶端無法感知并消費新增分區,需要客戶端重啟后,才能消費到新增分區。
當Sarama Go客戶端同時訂閱兩個以上的Topic時,有可能會導致部分分區無法正常消費消息。
當Sarama Go客戶端的消費位點重置策略設置為Oldest(earliest)時,如果客戶端宕機或服務端版本升級,由于Sarama Go客戶端自行實現OutOfRange機制,有可能會導致客戶端從最小位點開始重新消費所有消息。
解決方案
建議盡早將Sarama Go客戶端替換為Confluent Go客戶端。