* bind KinesisInputFormat class to module

apache · Jul 30, 2024 · 90e0f12 · 90e0f12
1 parent ba4d447
commit 90e0f12
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...service/src/main/java/org/apache/druid/indexing/kinesis/KinesisIndexingServiceModule.java b/...service/src/main/java/org/apache/druid/indexing/kinesis/KinesisIndexingServiceModule.java
@@ -26,6 +26,7 @@
 import com.google.inject.Binder;
 import com.google.inject.name.Names;
 import org.apache.druid.common.aws.AWSCredentialsConfig;
+import org.apache.druid.data.input.kinesis.KinesisInputFormat;
 import org.apache.druid.guice.JsonConfigProvider;
 import org.apache.druid.indexing.kinesis.supervisor.KinesisSupervisorSpec;
 import org.apache.druid.indexing.kinesis.supervisor.KinesisSupervisorTuningConfig;
@@ -50,7 +51,8 @@ public List<? extends Module> getJacksonModules()
                 new NamedType(KinesisIndexTaskIOConfig.class, SCHEME),
                 new NamedType(KinesisSupervisorTuningConfig.class, SCHEME),
                 new NamedType(KinesisSupervisorSpec.class, SCHEME),
-                new NamedType(KinesisSamplerSpec.class, SCHEME)
+                new NamedType(KinesisSamplerSpec.class, SCHEME),
+                new NamedType(KinesisInputFormat.class, SCHEME)
             )
     );
   }