读取 Apache Kafka 中的多个主题

Question

我正在尝试使用 logstash 输入插件中的 'white_list' 配置来读取多个 kafka 主题（比如 'newtest-1' 和 'newtest-2'）。我的 logstash conf 看起来像：

input { kafka { white_list => "newtest-1|newtest-2" } } output { stdout {codec => rubydebug } }

通过这种配置，我可以成功阅读两个不同的主题。但我想对输入主题使用正则表达式，因为我希望主题的形式为 'newtest-*'。根据 this link 中的建议，以下配置应该有效：

input { kafka { white_list => "newtest-*" } } output { stdout {codec => rubydebug } }

但是有了这个我无法从卡夫卡读取。感谢任何帮助。

Answer 1

white_list 应该是 newtest-.* 这与旧版本的插件有关。现在您可以使用 topics。