java - 如何使用 Reactive Kafka 将字符串数据发送到 kafka 生产者？

Question

我有一个字符串格式的数据。我需要将它发送给 kafka 生产者到特定分区，但使用反应式 kafka，即进行异步调用。如何使用代码实现这一点？我检查了响应式 kafka 文档，但不幸的是我对 Java Rx(Mono/Flux) 等不太了解。

如果有人可以提供帮助，那就太好了。欢迎任何需要更多细节的问题。

我能够以非矫正的方式做到这一点。