waltermcq
11/18/2020, 7:18 PM// send data - asynchronous
producer.send(record, new Callback() {
public void onCompletion(RecordMetadata recordMetadata, Exception e) {
// executes every time a record is successfully sent or an exception is thrown
if (e == null) {
// the record was successfully sent
<http://logger.info|logger.info>("Received new metadata. \n" +
"Topic:" + recordMetadata.topic() + "\n" +
"Partition: " + recordMetadata.partition() + "\n" +
"Offset: " + recordMetadata.offset() + "\n" +
"Timestamp: " + recordMetadata.timestamp());
} else {
logger.error("Error while producing", e);
}
}
});
}
fun Callback.onCompletion(recordMetadata: RecordMetadata, e: Exception) { ... }
akatkov
11/18/2020, 8:23 PM// send data - asynchronous
producer.send(record, object: Callback() {
fun onCompletion(recordMetadata: RecordMetadata, e: Exception?) {
// executes every time a record is successfully sent or an exception is thrown
if (e == null) {
// the record was successfully sent
<http://logger.info|logger.info>("Received new metadata. \n" +
"Topic:" + recordMetadata.topic() + "\n" +
"Partition: " + recordMetadata.partition() + "\n" +
"Offset: " + recordMetadata.offset() + "\n" +
"Timestamp: " + recordMetadata.timestamp())
} else {
logger.error("Error while producing", e)
}
}
})
fun onCompletion
)waltermcq
11/18/2020, 8:31 PM