Kafka流：一个记录到多个记录

Question

给定：我在Kafka中有两个主题，假设主题A和主题B。Kafka流从主题A中读取一条记录，对其进行处理，并产生与所消耗记录相对应的多条记录（假设recordA和recordB）。现在的问题是我如何使用Kafka流来实现这一点。

KStream<String, List<Message>> producerStreams[] = recordStream.mapValues(new ValueMapper<Message, List<Message>>() {
        @Override
        public List<Message> apply(final Message message) {
          return consumerRecordHandler.process(message);
        }
    }).*someFunction*()

在这里，读取的记录是消息；处理之后，它返回一个消息列表。如何将此列表划分为两个生产者流？任何帮助都将不胜感激。

Answer 1

我不确定我是否正确理解了这个问题，我也不明白@Abhishek的答案：（

如果您有一个输入流，并且希望每个输入记录获得零条、一条或多条输出记录，那么您可以应用FlatMap()或FlatMapValues()（取决于您是否希望修改键）。

您还在询问“如何将此列表划分为两个制作人流？”如果要将一个流拆分为多个流，可以使用branch()。

有关更多细节，请参阅文档:https://docs.confluent.io/platform/current/streams/developer-guide/dsl-api.html#stateless-transformations