+ return send(record);
+ }
+
+ @PostMapping(path = "/")
+ public DeferredResult<ProduceResult> greeting(
+ @RequestBody String name)
+ {
+ final ProducerRecord<String, Object> record = new ProducerRecord<>(
+ topic, // Topic
+ name, // Key
+ new Greeting(name) // Value
+ );
+
+ return send(record);
+ }
+
+ private DeferredResult<ProduceResult> send(ProducerRecord<String, Object> record)
+ {
+ DeferredResult<ProduceResult> result = new DeferredResult<>();
+
+ final long time = System.currentTimeMillis();
+