fix(providers): add missing TopicMaxNumPartitionsValidation

streamthoughts · Sep 11, 2024 · bab36ae · bab36ae
1 parent 4193c4b
commit bab36ae
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...u-provider-kafka/src/main/java/io/streamthoughts/jikkou/kafka/KafkaExtensionProvider.java b/...u-provider-kafka/src/main/java/io/streamthoughts/jikkou/kafka/KafkaExtensionProvider.java
@@ -48,6 +48,7 @@
 import io.streamthoughts.jikkou.kafka.validation.NoDuplicatePrincipalRoleValidation;
 import io.streamthoughts.jikkou.kafka.validation.NoDuplicateTopicsAllowedValidation;
 import io.streamthoughts.jikkou.kafka.validation.TopicConfigKeysValidation;
+import io.streamthoughts.jikkou.kafka.validation.TopicMaxNumPartitionsValidation;
 import io.streamthoughts.jikkou.kafka.validation.TopicMaxReplicationFactorValidation;
 import io.streamthoughts.jikkou.kafka.validation.TopicMinNumPartitionsValidation;
 import io.streamthoughts.jikkou.kafka.validation.TopicMinReplicationFactorValidation;
@@ -103,6 +104,7 @@ public void registerExtensions(@NotNull ExtensionRegistry registry) {
         registry.register(TopicMinReplicationFactorValidation.class, TopicMinReplicationFactorValidation::new);
         registry.register(TopicMaxReplicationFactorValidation.class, TopicMaxReplicationFactorValidation::new);
         registry.register(TopicMinNumPartitionsValidation.class, TopicMinNumPartitionsValidation::new);
+        registry.register(TopicMaxNumPartitionsValidation.class, TopicMaxNumPartitionsValidation::new);
         registry.register(TopicNameRegexValidation.class, TopicNameRegexValidation::new);
         registry.register(TopicNamePrefixValidation.class, TopicNamePrefixValidation::new);
         registry.register(TopicNameSuffixValidation.class, TopicNameSuffixValidation::new);