你可以用 flatMap() 或者 flatMapValues() 方法。这些方法获取一条记录并生成零条、一条或多条记录。 flatMap() 可以修改键、值及其数据类型，同时 flatMapValues() 保留原始键并更改值和值数据类型。
下面是一个伪代码示例，考虑到新消息“c”、“d”、“e”将有一个新密钥。

KStream<byte[], String> inputStream = builder.stream("inputTopic");
KStream<byte[], String> outStream = inputStream.flatMap( 
           (key,value)->{
            List<KeyValue<byte[], String>> result = new LinkedList<>();  
                // If message value is "B". Otherwise place your condition based on data     
                if(value.equalsTo("B")){ 
                      result.add(KeyValue.pair("<new key for message C>","C"));
                      result.add(KeyValue.pair("<new key for message D>","D"));
                      result.add(KeyValue.pair("<new key for message E>","E"));

                 }else{
                         result.add(KeyValue.pair(key,value));
                 }
            return result;
});
outStream.to("sinkTopic");

您可以阅读更多信息：https://docs.confluent.io/current/streams/developer-guide/dsl-api.html#streams-开发者指南dsl转换无状态