-
- void send(String key, String value)
- {
- ListenableFuture<SendResult<String, String>> listenableFuture =
- kafkaTemplate.send("test", key, value);
-
- 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));
- }
-