亚洲激情专区-91九色丨porny丨老师-久久久久久久女国产乱让韩-国产精品午夜小视频观看

溫馨提示×

kafka怎么判斷是否發送成功

小億
761
2023-10-20 18:49:03
欄目: 大數據

在 Kafka 中,生產者發送消息后,可以通過以下幾種方式判斷消息是否發送成功:

  1. 同步發送方式:生產者調用 send() 方法后,會等待消息的確認返回,如果發送成功,send() 方法會返回一個 RecordMetadata 對象,其中包含了消息的元數據信息;如果發送失敗,則可能拋出異常。
ProducerRecord<String, String> record = new ProducerRecord<>("topicName", "key", "value");
try {
    RecordMetadata metadata = producer.send(record).get();
    System.out.println("消息發送成功,offset:" + metadata.offset());
} catch (Exception e) {
    System.out.println("消息發送失敗:" + e.getMessage());
}
  1. 異步發送方式:生產者調用 send() 方法后,可以傳遞一個回調函數,在消息發送完成后,會調用該回調函數,通過回調函數可以獲取到發送結果。
ProducerRecord<String, String> record = new ProducerRecord<>("topicName", "key", "value");
producer.send(record, new Callback() {
    @Override
    public void onCompletion(RecordMetadata metadata, Exception e) {
        if (e != null) {
            System.out.println("消息發送失敗:" + e.getMessage());
        } else {
            System.out.println("消息發送成功,offset:" + metadata.offset());
        }
    }
});

無論是同步發送還是異步發送,如果發送失敗,可以根據異常信息進行錯誤處理。

0
沙雅县| 九龙县| 澄迈县| 乌海市| 两当县| 军事| 手游| 瓮安县| 大同市| 舟曲县| 渑池县| 米易县| 沧源| 凤城市| 华池县| 佛山市| 大竹县| 留坝县| 来凤县| 嘉善县| 贵州省| 大港区| 玉屏| 比如县| 苍山县| 额尔古纳市| 文登市| 邯郸县| 磐石市| 宿州市| 永福县| 弋阳县| 惠水县| 南充市| 社会| 荥经县| 曲沃县| 闽侯县| 泰安市| 白玉县| 霍城县|