给定：我在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*()

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