kafka 如何优先级消费?

不敢 发表于: 2022-02-22   最后更新时间: 2022-02-22 12:30:49   1,280 游览

kafka如何优先级消费?

比如:优先级低的100万在队列消费,优先级高的100万过来的时候,就先消费优先级高的。

发表于 2022-02-22
添加评论

kafka没有相关的功能,只能靠你的消费者逻辑来实现(很复杂,还要增加队列和线程池,如果宕机数据全丢了等)。

另外,我想到变通的方式是:

  • 暂停/恢复消费,查看kafka消费者Java客户端,搜索关键字「消费者流量控制」。
  • 设置消费者拉取批次的数据量,通过设置不同的的比例,达到你的效果。
你的答案

查看kafka相关的其他问题或提一个您自己的问题