开发者社区> 问答> 正文

使用Sarama对接消息队列kafka版本有问题

已解决

使用Sarama对接消息队列kafka版本有问题

展开
收起
提个问题 2024-06-08 13:08:04 55 0
1 条回答
写回答
取消 提交回答
  • 开发者社区问答官方账号
    官方回答
    采纳回答
    并不推荐 Sarama客户端收发消息,go语言推荐使用Confluent Go客户端
    Sarama客户端已知会有以下问题
    • 当Topic新增分区时,Sarama Go客户端无法感知并消费新增分区,需要客户端重启后,才能消费到新增分区。
    • 当Sarama Go客户端同时订阅两个以上的Topic时,有可能会导致部分分区无法正常消费消息。
    • 当Sarama Go客户端的消费位点重置策略设置为Oldest(earliest)时,如果客户端宕机或服务端版本升级,由于Sarama Go客户端自行实现OutOfRange机制,有可能会导致客户端从最小位点开始重新消费所有消息。
    2024-06-08 13:08:06
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
企业互联网架构之消息队列 立即下载
基于消息队列RocketMQ的大型分布式应用上云最佳实践 立即下载
云原生消息队列Apache RocketMQ 立即下载