@Reflective and ReflectiveProcessor support for KafkaListener

[MatejNedic]

Hey,

I am working on adapting Native hints for Spring Cloud AWS SQS and since I am looking into Spring Kafka for inspiration I noticed @KafkaListener is not annotated with @Reflective and is not marking parameters for reflection.
Since I am not that to deep into Spring Kafka internals I am not sure if this is needed or you are doing it some other way. If it is something you think is good and would be useful to a project I am willing to make a PR!

[garyrussell]

See

spring-kafka/spring-kafka/src/main/java/org/springframework/kafka/aot/KafkaRuntimeHints.java

Lines 89 to 96 in 08e76d3

	/**
	* {@link RuntimeHintsRegistrar} for Spring for Apache Kafka.
	*
	* @author Gary Russell
	* @since 3.0
	*
	*/
	public class KafkaRuntimeHints implements RuntimeHintsRegistrar {

We did add some code to detect AVRO types in listener methods, but everything works without @Reflective on @KafkaListener.

spring-kafka/spring-kafka/src/main/java/org/springframework/kafka/aot/KafkaAvroBeanRegistrationAotProcessor.java

Lines 38 to 46 in 08e76d3

	/**
	* Detect and register Avro types for Apache Kafka listeners.
	*
	* @author Gary Russell
	* @since 3.0
	*
	*/
	public class KafkaAvroBeanRegistrationAotProcessor implements BeanRegistrationAotProcessor {

[MatejNedic]

Ohhhh didn't see that part for Avro. Sorry for raising a false flag then 😅.

I have seen a RuntimeHintsRegistrar, but without checking internals of Spring Kafka and Spring Messaging it is hard to know really what hints represent. We had issue where class that has @SqsListener needed to be marked for reflection and Class which is Parameter of a method as well since Mapping2Jackson would fail otherwise.
Thanks on quick answer.

[artembilan]

The @KafkaListener is marked as @MessageMapping, which, in turn, is @Reflective(MessageMappingReflectiveProcessor.class).
but I see that @SqsListener is not:

@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface SqsListener {

So, that's an answer for you how it work in Spring for Apache Kafka.

[garyrussell]

Thanks, @artembilan I had forgotten about @MessageMapping; it's been there since day 1.

[MatejNedic]

Have missed that annotation. Thanks. I have created my own Processor in PR for native hints, but will replace it with @MessageMappin tnx @artembilan