我有一个字符串格式的数据。我需要把它发送到Kafka生产者到一个特定的分区,但使用ReactKafkaie作出异步调用。如何使用代码实现这一点?我查看了React式kafka文档,但不幸的是,我对javarx(mono/flux)等不太了解。如果有人能帮忙就太好了。任何需要更多细节的问题都欢迎。我可以用非直接的方式做这件事。
目前还没有任何答案,快来回答吧!
暂无答案!
目前还没有任何答案,快来回答吧!