Skip to content

Commit 2284547

Browse files
committed
Add missing Kafka Streams 3.7.0 native hints
1 parent a039bbf commit 2284547

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

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

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright 2022-2023 the original author or authors.
2+
* Copyright 2022-2024 the original author or authors.
33
*
44
* Licensed under the Apache License, Version 2.0 (the "License");
55
* you may not use this file except in compliance with the License.
@@ -91,6 +91,7 @@
9191
* {@link RuntimeHintsRegistrar} for Spring for Apache Kafka.
9292
*
9393
* @author Gary Russell
94+
* @author Soby Chacko
9495
* @since 3.0
9596
*
9697
*/
@@ -205,6 +206,8 @@ public void registerHints(RuntimeHints hints, @Nullable ClassLoader classLoader)
205206
"org.apache.kafka.streams.processor.internals.assignment.HighAvailabilityTaskAssignor",
206207
"org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignor",
207208
"org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor",
209+
"org.apache.kafka.streams.state.BuiltInDslStoreSuppliers$RocksDBDslStoreSuppliers",
210+
"org.apache.kafka.streams.state.BuiltInDslStoreSuppliers$InMemoryDslStoreSuppliers",
208211
"org.apache.kafka.streams.errors.LogAndFailExceptionHandler")
209212
.forEach(type -> reflectionHints.registerTypeIfPresent(classLoader, type, builder ->
210213
builder.withMembers(MemberCategory.INVOKE_PUBLIC_CONSTRUCTORS)));

0 commit comments

Comments
 (0)