{
for (int i = 0; i < 100; i++)
{
+ // tag::callback[]
ListenableFuture<SendResult<String, String>> listenableFuture =
kafkaTemplate.send("test", Long.toString(i%10), Long.toString(i));
result.getRecordMetadata().partition(),
result.getRecordMetadata().offset()),
e -> log.error("ERROR sendig message", e));
+ // end::callback[]
}
}