你如何使用带有 Flux 或 Mono 的 @KafkaListener 注释方法？

How do you use a @KafkaListener annotated method with a Flux or Mono?

如何在 Flux 或 Mono 中使用 @KafkaListener 注释方法？

你不能；尚不支持；我们希望今年能看到它；欢迎投稿。

同时，看看 reactor-kafka 项目。