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

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

For Existing Member Sign In

This topic created in 1130 days ago, the information mentioned may be changed or developed.

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

5 replies • 2023-04-04 13:51:16 +08:00

alexfarm

Apr 3, 2023

好吧，chatgpt 已经告诉我 topic 得是固定的，还是动态创建一个 consumer client 吧

lalawu

Apr 3, 2023

@alexfarm 针对这个场景，可以考虑用发布订阅轻量级的 redis 也可以啊

alexfarm

Apr 3, 2023

@lalawu 是的，一开始打算用 redis 的队列来实现，第一个是组里好像不太推崇 redis ，第二个是没有持久化。

Muzhijiao

Apr 4, 2023 via Android

听上去有点像正则表达式匹配 topic

duanguyuan

Apr 4, 2023

可以啊，用 consumer.assign()方法