我正在做一个将 Spring Cloud Gateway 与 Reactive Kafka 集成的原型。我的目标是将帖子主体推向卡夫卡。我可以使用Flux，这可能会给我大块的身体。需要专家建议如何将 DataBuffer 的 Flux 转换为 SenderRecord 并将其推送到 kafka 非阻塞。
我尝试使用DataBufferUtils.join合并 DataBuffer 以获取字节 [] 并使用它创建一个 SenderRecord。有没有更好的方法（我们可以避免分配字节数组）吗？
实现细节：我有kafka的Spring Cloud Gateway Global Filter（url结构：kafka://<producer-template>?topic=<topicname>。然后读取body，即flux并创建kafkaSender。
谢谢你。