fix(ingestion): set schema registry URL correctly for FMCE producer (#…

…1839) Fixes #1829
datahub-project · Aug 31, 2020 · f4bccaf · f4bccaf
1 parent 85a6cd1
commit f4bccaf
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...a-jobs/mce-consumer-job/src/main/java/com/linkedin/metadata/kafka/config/KafkaConfig.java b/...a-jobs/mce-consumer-job/src/main/java/com/linkedin/metadata/kafka/config/KafkaConfig.java
@@ -74,7 +74,7 @@ public KafkaTemplate<String, GenericRecord> kafkaTemplate(KafkaProperties proper
     props.put(AbstractKafkaAvroSerDeConfig.SCHEMA_REGISTRY_URL_CONFIG, kafkaSchemaRegistryUrl);
 
     KafkaTemplate<String, GenericRecord> template =
-        new KafkaTemplate<>(new DefaultKafkaProducerFactory<>(properties.buildProducerProperties()));
+        new KafkaTemplate<>(new DefaultKafkaProducerFactory<>(props));
 
     log.info("KafkaTemplate built successfully");