Kotlin suspend functions return type is incorrect about spring-amqp HOT 3 CLOSED

@PsyBrainy ,

It would be great if you ask such a question in Spring for Apache Kafka project by itself.

Yes, that work has been done for the @KafkaListener as well. See respective GH issue: spring-projects/spring-kafka#1189.

And docs for upcoming 3.2 version: https://docs.spring.io/spring-kafka/reference/3.2/whats-new.html#x32-async-return

from spring-amqp.

Thank you @artembilan for the quick fix.

from spring-amqp.

Hello @abelmulq and @artembilan,

I've been following the discussion on Kotlin suspend function return types and appreciate the fixes and updates made. I am curious if similar support or modifications have been considered for the KafkaListener in the context of handling Kafka messages with Kotlin coroutines? Specifically, is there any ongoing work or planned updates to ensure that KafkaListeners can handle return types correctly when used with Kotlin suspend functions?

Thank you for your efforts and any information you can provide on this matter.

from spring-amqp.