如何将匹配特定条件的记录发送到Spring apache kafka中的特定/多个输出主题

Question

我已经提到了这一点。但是，这是一个老帖子，所以我正在寻找一个更好的解决方案。

我有一个包含"userActivity"数据的输入主题。现在，我希望收集基于userInterest、userSubscribedGroup、userChoice等的不同分析，这些分析是为同一Kafka流应用程序的不同输出主题而生成的。

你能帮我实现这个吗。。。ps：这是我第一次使用Kafka流，所以我不知道还有其他选择。

编辑：

一条记录可能匹配多个条件，在这种情况下，同一条记录也应该进入这些输出主题。

if(record1 matches criteria1) then... output to topic1;
if(record1 matches criteria2) then ... output to topic2;
and so on.
note: i'm not looking elseIf kind of solution.

Answer 1

用于在运行时根据每条记录的键值对动态选择发送到哪个主题。Apache Kafka 2.0或更高版本引入了一个名为：动态路由的功能

这是一个例子：https://kafka-tutorials.confluent.io/dynamic-output-topic/confluent.html