0

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);
  }

});

4

1 回答 1

0

不; EventHubProducerClient 不会延迟发送事件。当您调用 时SendAsync,会立即发布这批事件。当该调用完成时,事件中心服务已成功确认事件或将出现异常。

有关使用事件中心 SDK 发布事件的更多信息和更深入的讨论,您可能需要查看此示例

于 2021-08-03T14:07:38.790 回答