kafka 的 consumer 是否支持动态切换 topic?

2023-04-03 20:36:50 +08:00
 alexfarm

在设计一个自动外呼系统,打算使用 kafka 来实现 外呼名单->外呼 这一个分布式队列场景,但业务上需要切换外呼名单的优先级,打算把不同优先级放在不同 topic 中,请问可以原生 api 中支持动态调整吗

1511 次点击
所在节点    Java
5 条回复
alexfarm
2023-04-03 21:02:41 +08:00
好吧,chatgpt 已经告诉我 topic 得是固定的,还是动态创建一个 consumer client 吧
lalawu
2023-04-03 21:08:39 +08:00
@alexfarm 针对这个场景,可以考虑用发布订阅 轻量级的 redis 也可以啊
alexfarm
2023-04-03 21:11:07 +08:00
@lalawu 是的,一开始打算用 redis 的队列来实现,第一个是组里好像不太推崇 redis ,第二个是没有持久化。
Muzhijiao
2023-04-04 07:38:49 +08:00
听上去有点像正则表达式匹配 topic
duanguyuan
2023-04-04 13:51:16 +08:00
可以啊,用 consumer.assign()方法

这是一个专为移动设备优化的页面(即为了让你能够在 Google 搜索结果里秒开这个页面),如果你希望参与 V2EX 社区的讨论,你可以继续到 V2EX 上打开本讨论主题的完整版本。

https://www.v2ex.com/t/929526

V2EX 是创意工作者们的社区,是一个分享自己正在做的有趣事物、交流想法,可以遇见新朋友甚至新机会的地方。

V2EX is a community of developers, designers and creative people.

© 2021 V2EX