在Kafka中,我知道我可以为我的消费者订阅多个主题:
在我的例子中,我不能直接传递主题列表或模式,因为主题列表是事先不知道的。
例如,用户将在早晨使用UI指定一个主题(例如),在晚上指定第二个主题,因此使用者将完成这两个主题的订阅。
有可能这样做吗?
发布于 2020-10-27 16:18:05
您可以使用subscribe
和KafkaConsumer的unsubscribe
API动态地更改使用者的订阅。
如果使用key=subscribe/unsubscribe
和value=topic1/topic2/...
向订阅主题之一发送消息,则可以在使用者中实现基于这些消息更改订阅的逻辑。
https://stackoverflow.com/questions/64563907
复制