-
Notifications
You must be signed in to change notification settings - Fork 1.5k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
On kotlin application, Spring kafka 3.2.0 doesn't take the message conversion logic, because of the wrong coroutine detection on MessagingMessageListenerAdapter #3277
Comments
Looks like we have overseen this scenario when we tested Kotlin support for
That Feel free to contribute the fix as you have just explained. Thanks |
@artembilan Thank you for your feedback on my opinion. Okay, then I will submit a pull request to resolve this issue. |
In what version(s) of Spring for Apache Kafka are you seeing this issue?
For example:
3.2.0
Between 3.1.4 and 3.2.0
Describe the bug
On the MessagingMessageListenerAdapter class there is a bug on the
determineInferredType
method.if you determine the coroutine function, you should have to use
not
isKotlinType
methodbecause on kotlin,
@KafkaListener
method parameter type is always kotlin type. So theconversionNeeded
flag changes to false.This occurs messageConverters not working normally.
To Reproduce
Expected behavior
consumes normally and execute the
execute()
method but it occursMethodArgumentNotValidException
exceptionSample
sample is on the issue
The text was updated successfully, but these errors were encountered: