Call get()
on the future returned by Producer.send(...), or if you don't want to block your code, pass a callback.
try {
producer.send(new ProducerRecord("mytopic", key, value))
.get(); // block until acknowledged
} catch(Exception e) {
// handle message wasn't acknowledged
}