Azure EventHub 的 eventthubproducer 的 send 方法中是否有任何可用的回调机制,就像我们对 Kafka 一样。例如,以下代码适用于 Kafka Producer:-
producer.send(producerRecord, (recordMetadata, exception) -> {
if (exception == null) {
System.out.println("Record written to offset " +
recordMetadata.offset() + " timestamp " +
recordMetadata.timestamp());
} else {
System.err.println("An error occurred");
exception.printStackTrace(System.err);
}
});