我想使用状态存储（RocksDB）将一条记录转换为多条记录。我知道有一种方法，例如stream.transform(final TransformerSupplier> TransformerSupplier,final String... stateStoreNames)，但如何返回多个KeyValue对，以便我稍后可以使用分支发布到受尊重的主题？
有一种方法可以将数据转发到下游，但如何再次使用该数据？
卡夫卡版本 - 1.1.0
java apache-kafka apache-kafka-streams
apache-kafka ×1
apache-kafka-streams ×1
java ×1