在设计一个自动外呼系统,打算使用 kafka 来实现 外呼名单->外呼 这一个分布式队列场景,但业务上需要切换外呼名单的优先级,打算把不同优先级放在不同 topic 中,请问可以原生 api 中支持动态调整吗
1
alexfarm OP 好吧,chatgpt 已经告诉我 topic 得是固定的,还是动态创建一个 consumer client 吧
|
3
alexfarm OP @lalawu 是的,一开始打算用 redis 的队列来实现,第一个是组里好像不太推崇 redis ,第二个是没有持久化。
|
4
Muzhijiao 2023-04-04 07:38:49 +08:00 via Android
听上去有点像正则表达式匹配 topic
|
5
duanguyuan 2023-04-04 13:51:16 +08:00
可以啊,用 consumer.assign()方法
|