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

Question

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

Answer 1

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

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