阅读 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链接中的建议，以下配置应该可以工作：

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

但是有了这个，我无法从 kafka 中读取。任何帮助表示赞赏。

Answer 1

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