【发布时间】:2019-06-28 18:15:48
【问题描述】:
希望消费者订阅我*的所有主题
当消费者已经启动并运行时,可能会在 kafka 集群中创建以 I 开头的新主题
有没有办法让 kafka 集群/代理可以自动为消费者订阅以 I 开头的新主题
进行这种动态主题过滤/发现/订阅的唯一方法是由消费者在每个时间间隔调用元数据刷新并检查添加的新主题吗?
【问题讨论】:
标签: apache-kafka
希望消费者订阅我*的所有主题
当消费者已经启动并运行时,可能会在 kafka 集群中创建以 I 开头的新主题
有没有办法让 kafka 集群/代理可以自动为消费者订阅以 I 开头的新主题
进行这种动态主题过滤/发现/订阅的唯一方法是由消费者在每个时间间隔调用元数据刷新并检查添加的新主题吗?
【问题讨论】:
标签: apache-kafka
消费者是订阅和投票的人。代理不会将此元数据推送给消费者。
【讨论】: