MessagingMessageListenerAdapter.determineInferredType not working when a custom annotation is present Kafka listener method argument

[namelessone667]

I have a kafka listener defined using @KafkaListener annotation with one input argument of type A.

If I add a customer annotation @annotation1 (for example for logging purposes) to this method argument then MessagingMessageListenerAdapter.determineInferredType returns type Object. When I remove my custom annotation then MessagingMessageListenerAdapter.determineInferredType return type A as expected.

The problem is probably with the condition on line 602:

spring-kafka/spring-kafka/src/main/java/org/springframework/kafka/listener/adapter/MessagingMessageListenerAdapter.java

Lines 600 to 602 in 146c491

	if (!isNotConvertible && !isMessageWithNoTypeInfo(parameterType)
	&& (methodParameter.getParameterAnnotations().length == 0
	|| methodParameter.hasParameterAnnotation(Payload.class))) {

[artembilan]

Would you mind to share with us a code which causes that problem?
Thanks

[garyrussell]

As you can see with that if test - if you add other annotations, you must also explicitly add @Payload.