Skip to content

Commit 6978968

Browse files
committed
Add accessor to ReflectionHints - parameter accessor calls wrap() using reflection.
1 parent f8b0f5c commit 6978968

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

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

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -72,6 +72,7 @@
7272
import org.springframework.kafka.core.ProducerFactory;
7373
import org.springframework.kafka.listener.ConsumerProperties;
7474
import org.springframework.kafka.listener.ContainerProperties;
75+
import org.springframework.kafka.support.KafkaMessageHeaderAccessor;
7576
import org.springframework.kafka.support.LoggingProducerListener;
7677
import org.springframework.kafka.support.ProducerListener;
7778
import org.springframework.kafka.support.serializer.DelegatingByTopicDeserializer;
@@ -102,6 +103,7 @@ public void registerHints(RuntimeHints hints, @Nullable ClassLoader classLoader)
102103
Stream.of(
103104
ConsumerProperties.class,
104105
ContainerProperties.class,
106+
KafkaMessageHeaderAccessor.class,
105107
ProducerListener.class)
106108
.forEach(type -> reflectionHints.registerType(type,
107109
builder -> builder.withMembers(MemberCategory.INVOKE_DECLARED_METHODS)));

0 commit comments

Comments
 (0)