package mib.microservice.commons.kafka;

import java.util.Map;
import java.util.Properties;

/**
 * Default/fallback config properties for a kafka producer
 * 
 * @author knittl
 *
 */
public class KafkaProducerDefaultProperties extends Properties {
	private static final long serialVersionUID = 1L;

	public KafkaProducerDefaultProperties() {
		this.put("serializer.class", "mib.microservices.util.JsonEncoder");
		this.put("key.serializer.class", "kafka.serializer.StringEncoder");
		this.put("partitioner.class", "kafka.producer.DefaultPartitioner");
		this.put("request.required.acks", "1");
	}
	
	public KafkaProducerDefaultProperties(Map<String, String> props) {
		this();
		
		this.putAll(props);
	}
}

@@ -372,44 +372,35 @@
 s%22, 
-%22mib.microservices.util.JsonEncoder%22
+JsonEncoder.class.getName()
 );%0A%09
@@ -429,25 +429,24 @@
 zer.class%22, 
-%22
 kafka.serial
@@ -463,17 +463,32 @@
 gEncoder
-%22
+.class.getName()
 );%0A%09%09thi
@@ -514,17 +514,16 @@
 class%22, 
-%22
 kafka.pr
@@ -547,17 +547,32 @@
 titioner
-%22
+.class.getName()
 );%0A%09%09thi

Use .class.getName() instead of hardcoded strings in default properties