In Kafka Streams 2.6, we need to register the task assignors as they …

…are instantiated at runtime by reflection
quarkusio · Feb 2, 2021 · 6f097f5 · 6f097f5
1 parent 47b98d1
commit 6f097f5
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/...s/deployment/src/main/java/io/quarkus/kafka/streams/deployment/KafkaStreamsProcessor.java b/...s/deployment/src/main/java/io/quarkus/kafka/streams/deployment/KafkaStreamsProcessor.java
@@ -68,6 +68,12 @@ private void registerCompulsoryClasses(BuildProducer<ReflectiveClassBuildItem> r
         reflectiveClasses.produce(new ReflectiveClassBuildItem(true, false, false, DefaultPartitionGrouper.class));
         reflectiveClasses.produce(new ReflectiveClassBuildItem(true, false, false, DefaultProductionExceptionHandler.class));
         reflectiveClasses.produce(new ReflectiveClassBuildItem(true, false, false, FailOnInvalidTimestamp.class));
+        reflectiveClasses.produce(new ReflectiveClassBuildItem(true, true, true,
+                org.apache.kafka.streams.processor.internals.assignment.HighAvailabilityTaskAssignor.class));
+        reflectiveClasses.produce(new ReflectiveClassBuildItem(true, true, true,
+                org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignor.class));
+        reflectiveClasses.produce(new ReflectiveClassBuildItem(true, true, true,
+                org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor.class));
     }
 
     private void registerClassesThatClientMaySpecify(BuildProducer<ReflectiveClassBuildItem> reflectiveClasses,