V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
alexfarm
V2EX  ›  Java

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

  •  
  •   alexfarm · 2023-04-03 20:36:50 +08:00 · 1517 次点击
    这是一个创建于 629 天前的主题,其中的信息可能已经有所发展或是发生改变。

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

    5 条回复    2023-04-04 13:51:16 +08:00
    alexfarm
        1
    alexfarm  
    OP
       2023-04-03 21:02:41 +08:00
    好吧,chatgpt 已经告诉我 topic 得是固定的,还是动态创建一个 consumer client 吧
    lalawu
        2
    lalawu  
       2023-04-03 21:08:39 +08:00
    @alexfarm 针对这个场景,可以考虑用发布订阅 轻量级的 redis 也可以啊
    alexfarm
        3
    alexfarm  
    OP
       2023-04-03 21:11:07 +08:00
    @lalawu 是的,一开始打算用 redis 的队列来实现,第一个是组里好像不太推崇 redis ,第二个是没有持久化。
    Muzhijiao
        4
    Muzhijiao  
       2023-04-04 07:38:49 +08:00 via Android
    听上去有点像正则表达式匹配 topic
    duanguyuan
        5
    duanguyuan  
       2023-04-04 13:51:16 +08:00
    可以啊,用 consumer.assign()方法
    关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   实用小工具   ·   2933 人在线   最高记录 6679   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 23ms · UTC 13:01 · PVG 21:01 · LAX 05:01 · JFK 08:01
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.