Apache Nifi 中的 publishKafka 处理器中的多个 kafka 主题

Question

我试图在 Apache Nifi 中拥有来自 Twitter（GetTwitter 处理器）的三个不同数据源，并且只有一个 PublishKafka_0_10 处理器。 我可以将来自三个不同数据源的数据放在单独的主题中的单个 Publish kafka 处理器中吗？

如果可以，谁能给我任何链接？

Answer 1

在这种情况下你可以做两件事：

1. 您可以使用三个PublishKafka_0_10 处理器并分别使用三个不同的主题名称对其进行配置。
2. 如果您只想坚持使用一个PublishKafka_0_10 处理器，那么您可以利用Topic 属性在PublishKafka_0_10 处理器中提供的ExpressionLanguage 支持。

在后一种情况下，您需要将三个GetTwitter 处理器分别连接到三个UpdateAttribute 处理器。配置UpdateAttribute 处理器并添加一个新属性，比如topicName，并为它们提供相关的主题名称。例如，如果您希望第一个 GetTwitter 处理器写入 politics 主题，请使用该名称对其进行配置。其他两个类似，给出相关名称。然后将三个success 关系从UpdateAttribute 处理器连接到PublishKafka_0_10 处理器。配置PublishKafka_0_10并将Topic属性设置为${topicName}