0003661: Kafka support in conjunction with a Confluent registry

JumpMind · Aug 9, 2018 · 812f7f4 · 812f7f4
1 parent 7012301
commit 812f7f4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/load/KafkaWriterFilter.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/load/KafkaWriterFilter.java
@@ -111,7 +111,7 @@ public KafkaWriterFilter(IParameterService parameterService) {
         this.topicBy = parameterService.getString(ParameterConstants.KAFKA_TOPIC_BY, KAFKA_TOPIC_BY_CHANNEL);
         this.messageBy = parameterService.getString(ParameterConstants.KAFKA_MESSAGE_BY, KAFKA_MESSAGE_BY_BATCH);
         this.confluentUrl = parameterService.getString(ParameterConstants.KAFKA_CONFLUENT_REGISTRY_URL);
-        this.schemaPackage = "com.element.schema.telematics";
+        this.schemaPackage = parameterService.getString(ParameterConstants.KAFKA_AVRO_JAVA_PACKAGE);
 
         configs.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, this.url);
         configs.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringSerializer");