如何知道事件是否成功发送给消费者？

Question

我有一个使用 Spring Stream Kafka 发布事件的主要服务，我有 2 个不同的服务使用这个事件。这些服务应该使用事件来完成这个过程。

Order Service(Publisher-OrderEvent) -- Stock Service(Listener-OrderEvent) -- Payment Service(Listener-OrderEvent)

（应完成库存检查和付款以完成订单）

如何才能知道这个事件是否从order service成功发送到这两个service呢？ 我需要知道其中一个是否已关闭。如果它关闭/其中一项服务无法收到事件，我需要取消订单服务。 你们有这个案例的示例实现吗？

提前谢谢你。

Answer 1

选项 1：使用指标和records-consumed-total

从消费者端，监控这个属性/metric with the client id：

kafka.consumer:type=consumer-fetch-manager-metrics,client-id="{client-id}"

查看records-consumed-total 属性的内部，一旦收到它就会增加。

---

选项 2：使用 回调

您也可以使用call back 来验证它是否已发送

"...完全非阻塞使用可以利用 Callback 参数提供一个回调，请求完成时将调用该回调。"

 ProducerRecord<byte[],byte[]> record = new ProducerRecord<byte[],byte[]>("the-topic", key, value);
 producer.send(myRecord,
               new Callback() {
                   public void onCompletion(RecordMetadata metadata, Exception e) {
                       if(e != null) {
                          e.printStackTrace();
                       } else {
                          //... your code message was received!!
                          System.out.println("The offset of the record we just sent is: " + metadata.offset());
                       }
                   }
               });