fix(datahub-client): Fix kafka config issue (#5403)

datahub-project · Jul 15, 2022 · 369c655 · 369c655
1 parent 2c48329
commit 369c655
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/...ntegration/java/datahub-client/src/main/java/datahub/client/kafka/KafkaEmitterConfig.java b/...ntegration/java/datahub-client/src/main/java/datahub/client/kafka/KafkaEmitterConfig.java
@@ -22,10 +22,12 @@ public class KafkaEmitterConfig {
   private final String bootstrap = "localhost:9092";
   @Builder.Default
   private final String schemaRegistryUrl = "http://localhost:8081";
-
+
+  @Builder.Default
   private final Map<String, String> schemaRegistryConfig = Collections.emptyMap();
+  @Builder.Default
   private final Map<String, String> producerConfig = Collections.emptyMap();
-
+  
   @Builder.Default
   private final EventFormatter eventFormatter = new EventFormatter(EventFormatter.Format.PEGASUS_JSON);