Skip to content

Commit 8fa56a8

Browse files
committed
Add missing reflection hints for Kafka Streams binder
Add missing reflection hints for org.apache.kafka.streams.processor.internals.NoOpProcessorWrapper.class in Kafka Streams binder. Signed-off-by: Soby Chacko <soby.chacko@broadcom.com>
1 parent 83b78fb commit 8fa56a8

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/aot/KafkaStreamsBinderRuntimeHints.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,8 @@ private static void registerKafkaStreamsReflectionHints(RuntimeHints hints) {
7777
org.apache.kafka.streams.errors.LogAndFailExceptionHandler.class,
7878
org.apache.kafka.streams.processor.FailOnInvalidTimestamp.class,
7979
org.apache.kafka.streams.processor.internals.DefaultKafkaClientSupplier.class,
80-
org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor.class)
80+
org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor.class,
81+
org.apache.kafka.streams.processor.internals.NoOpProcessorWrapper.class)
8182
.forEach(type -> reflectionHints.registerType(type,
8283
builder -> builder.withMembers(MemberCategory.INVOKE_DECLARED_METHODS)));
8384

0 commit comments

Comments
 (0)