- // tag::callback[]
- ListenableFuture<SendResult<String, String>> listenableFuture =
- kafkaTemplate.send("test", Long.toString(i%10), Long.toString(i));
-
- listenableFuture.addCallback(
- result -> log.info(
- "Sent {}={} to partition={}, offset={}",
- result.getProducerRecord().key(),
- result.getProducerRecord().value(),
- result.getRecordMetadata().partition(),
- result.getRecordMetadata().offset()),
- e -> log.error("ERROR sendig message", e));
- // end::callback[]