X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FRestProducer.java;h=bccc166de968854dce7dd44aa52f16553be844dd;hb=6ca7376ef5307be0f838401ea996fa8912c6f10b;hp=e564a666c33751de46bec1a78e0ae545fdeb7abd;hpb=39d1bd1fc7b641255efd598ca4f037bd529d5fe8;p=demos%2Fkafka%2Ftraining

diff --git a/src/main/java/de/juplo/kafka/RestProducer.java b/src/main/java/de/juplo/kafka/RestProducer.java
index e564a66..bccc166 100644
--- a/src/main/java/de/juplo/kafka/RestProducer.java
+++ b/src/main/java/de/juplo/kafka/RestProducer.java
@@ -40,6 +40,7 @@ public class RestProducer
     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);
   }