0004479: Confluent jackson modules missing from install

JumpMind · Jul 20, 2020 · c2ea651 · c2ea651
1 parent 209378a
commit c2ea651
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/symmetric-client/src/main/resources/symmetric-modules.properties b/symmetric-client/src/main/resources/symmetric-modules.properties
@@ -11,7 +11,7 @@ hsqldb=org.hsqldb:hsqldb:2.4.1
 ignite=org.apache.ignite:ignite-core:2.7.6
 informix=jdbc.informix:ifxjdbc:1.0, jdbc.informix:ifxlang:1.0
 interbase=jdbc.interbase:interclient:13.2.0
-kafka=org.apache.kafka:kafka-clients:1.1.0, org.lz4:lz4-java:1.4, org.xerial.snappy:snappy-java:1.1.7.1, org.apache.avro:avro:1.8.2, org.codehaus.jackson:jackson-mapper-asl:1.9.13, com.thoughtworks.paranamer:paranamer:2.7, org.xerial.snappy:snappy-java:1.1.7.1, org.apache.commons:commons-compress:1.8.1, org.tukaani:xz:1.5, io.confluent:kafka-avro-serializer:3.2.1, io.confluent:kafka-schema-registry-client:3.2.1, io.confluent:common-config:3.2.1, io.confluent:common-utils:3.2.1, com.101tec:zkclient:0.10, org.apache.zookeeper:zookeeper:3.4.8, jline:jline:0.9.94, io.netty:netty:3.7.0.Final, org.codehaus.jackson:jackson-core-asl:1.9.13
+kafka=org.apache.kafka:kafka-clients:1.1.0, org.lz4:lz4-java:1.4, org.xerial.snappy:snappy-java:1.1.7.1, org.apache.avro:avro:1.8.2, org.codehaus.jackson:jackson-mapper-asl:1.9.13, com.thoughtworks.paranamer:paranamer:2.7, org.xerial.snappy:snappy-java:1.1.7.1, org.apache.commons:commons-compress:1.8.1, org.tukaani:xz:1.5, io.confluent:kafka-avro-serializer:3.2.1, io.confluent:kafka-schema-registry-client:3.2.1, io.confluent:common-config:3.2.1, io.confluent:common-utils:3.2.1, com.101tec:zkclient:0.10, org.apache.zookeeper:zookeeper:3.4.8, jline:jline:0.9.94, io.netty:netty:3.7.0.Final, org.codehaus.jackson:jackson-core-asl:1.9.13, com.fasterxml.jackson.core:jackson-databind:2.10.3, com.fasterxml.jackson.core:jackson-annotations:2.10.3, com.fasterxml.jackson.core:jackson-core:2.10.3
 mariadb=org.mariadb.jdbc:mariadb-java-client:2.4.0
 mongodb=org.mongodb:mongo-java-driver:2.12.3
 mssql=jdbc.sqlserver:sqljdbc:4.0

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
@@ -47,6 +47,7 @@
 import org.apache.kafka.clients.producer.ProducerConfig;
 import org.apache.kafka.clients.producer.ProducerRecord;
 import org.apache.kafka.common.serialization.LongSerializer;
+import org.apache.kafka.common.serialization.StringSerializer;
 import org.jumpmind.db.model.Table;
 import org.jumpmind.properties.TypedProperties;
 import org.jumpmind.symmetric.common.ParameterConstants;
@@ -151,13 +152,13 @@ public KafkaWriterFilter(IParameterService parameterService) {
 
         if (kafkaProducer == null) {
 	        configs.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, this.url);
-	        configs.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringSerializer");
-	        configs.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringSerializer");
+	        configs.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
+	        configs.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
 	        configs.put(ProducerConfig.CLIENT_ID_CONFIG, this.producer);
 
 	        if (confluentUrl != null) {
 	            configs.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, KafkaAvroSerializer.class.getName());
-	            configs.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, LongSerializer.class.getName());
+	            configs.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
 
 	            configs.put(KafkaAvroSerializerConfig.SCHEMA_REGISTRY_URL_CONFIG, confluentUrl);
 	        }