+ void send(String key, String value)
+ {
+ ListenableFuture<SendResult<String, String>> listenableFuture =
+ kafkaTemplate.sendDefault(key, value);
+
+ listenableFuture.addCallback(
+ result -> log.debug(
+ "Sent {}={} to partition={}, offset={}",
+ result.getProducerRecord().key(),
+ result.getProducerRecord().value(),
+ result.getRecordMetadata().partition(),
+ result.getRecordMetadata().offset()),
+ e -> log.error("ERROR sendig message", e));