卡夫卡流 |如何根据通过流接收的内容动态添加 "to" 主题
Kafka Streams | How to add the "to" topic dynamically on the basis of content received over stream
我的问题很简单，但我无法弄清楚如何在 Java?
中使用 Kafka 流实现以下目标
- 我创建了一个连接到主题的 Kafka 流。
- 关于那个主题，我收到一个 json，其中包含数据和另一个主题的名称。
我想将收到的 json 内容转发到另一个主题。
在 Kafka 1.1 或更早版本中，您需要使用 KStream#branch() 将流拆分为子流（每个输出主题一个），然后添加一个接收器（即 KStream#to() 为每个输出主题。
在即将发布的 2.0 版本中，添加了动态路由功能，允许您根据消息内容动态提取 sink-topic 名称。比照。 https://cwiki.apache.org/confluence/display/KAFKA/KIP-303%3A+Add+Dynamic+Routing+in+Streams+Sink 了解详情。
我的问题很简单，但我无法弄清楚如何在 Java?
中使用 Kafka 流实现以下目标- 我创建了一个连接到主题的 Kafka 流。
- 关于那个主题，我收到一个 json，其中包含数据和另一个主题的名称。
我想将收到的 json 内容转发到另一个主题。
在 Kafka 1.1 或更早版本中，您需要使用 KStream#branch() 将流拆分为子流（每个输出主题一个），然后添加一个接收器（即 KStream#to() 为每个输出主题。
在即将发布的 2.0 版本中，添加了动态路由功能，允许您根据消息内容动态提取 sink-topic 名称。比照。 https://cwiki.apache.org/confluence/display/KAFKA/KIP-303%3A+Add+Dynamic+Routing+in+Streams+Sink 了解详情。