props.put("value.serializer", JsonSerializer.class.getName());
props.put(JsonSerializer.TYPE_MAPPINGS,
"message:" + ClientMessage.class.getName() + "," +
+ "foo:" + FooMessage.class.getName() + "," +
"greeting:" + Greeting.class.getName());
this.producer = new KafkaProducer<>(props);
return send(record);
}
+ @PutMapping(path = "{key}")
+ public DeferredResult<ProduceResult> message(@PathVariable String key)
+ {
+ key = key.trim();
+ final ProducerRecord<String, Object> record = new ProducerRecord<>(
+ topic, // Topic
+ key, // Key
+ new FooMessage(key, System.currentTimeMillis()) // Value
+ );
+
+ return send(record);
+ }
+
@PostMapping(path = "/")
public DeferredResult<ProduceResult> greeting(
@RequestBody String name)