props.put("compression.type", properties.getCompressionType());
props.put("key.serializer", StringSerializer.class.getName());
props.put("value.serializer", JsonSerializer.class.getName());
+ props.put(JsonSerializer.TYPE_MAPPINGS, "message:" + ClientMessage.class.getName());
this.producer = new KafkaProducer<>(props);
}