apache-kafka - 使用来自 kafka 主题的数据的通用方法

Question

有没有办法获取所有 kafka 主题的列表并使用 kafka gererically 从中使用所有数据。我们实际上想要捕获在 kafka 内部流动的任何类型的数据。

Answer 1

订阅消费者时，您可以指定正则表达式模式而不是主题列表，请参阅subscribe()方法。

通过传递一个正则表达式来匹配所有（如.+），它将订阅并开始使用所有主题。