接收和返回反应式类型apache kafka with micronaut 2.1.3

import io.micronaut.configuration.kafka.annotation.KafkaClient;
import io.micronaut.configuration.kafka.annotation.KafkaKey;
import io.micronaut.configuration.kafka.annotation.KafkaListener;
import io.micronaut.configuration.kafka.annotation.OffsetReset;
import io.micronaut.configuration.kafka.annotation.Topic;
import jakarta.inject.Singleton;

@KafkaClient
public interface KafkaProducer {
    void sendMessage(@Topic("my-topic") String message);
}

@Singleton
public class MessageService {

    private final KafkaProducer kafkaProducer;

    public MessageService(KafkaProducer kafkaProducer) {
        this.kafkaProducer = kafkaProducer;
    }

    public void sendMessage(String message) {
        kafkaProducer.sendMessage(message);
    }
}

@KafkaListener(offsetReset = OffsetReset.EARLIEST)
public class KafkaConsumer {

    @KafkaListener(topics = "my-topic", groupId = "my-group")
    public void receive(@KafkaKey String key, String message) {
        System.out.println("Received message: " + message);
    }
}