= 0; i < 10; i++) { String data = "The msg is " + i; producer.send(new ProducerRecord<>(TOPIC, data), new Callback() { public void onCompletion(RecordMetadata metadata, Exception exception) { if (exception !
= 0; i < 10; i++) { String data = "The msg is " + i; producer.send(new ProducerRecord<>(TOPIC, data), new Callback() { public void onCompletion(RecordMetadata metadata, Exception exception) { if (exception !