Kafka+Spark Streaming保證exactly once語義

在Kafka、Flink、Spark Streaming等分佈式流處理系統中(Kafka本質上市流處理系統,不單是MQ),存在三種消息傳遞語義(Message Delivery Semantics): At Least Once 每條消息會被收到1次或多次。例如發送方S在超時時間內沒有收到接收方R的通知,或者收到了R的報錯,就會不斷重發消息直至R傳回ACK At Most Once 每條消息會被收
相關文章
相關標籤/搜索