Apache Flink结合Apache Kafka实现端到端的一致性语义
流计算中的一致性语义定义，以及通常系统怎么支持一致性语义，Flink+Fafka如何实现端到端的一致性语义。
展开查看详情
1.Apache Kafka x Apache Flink·
18.Exactly Once
At least once + • •
• •
At least once + • •
• • barrier
•
Region Failover: FLINK-
4256
•
28.public interface CheckpointListener {
/**
* This method is called as a notification once a distributed checkpoint has been completed.
*
* Note that any exception during this method will not cause the checkpoint to
* fail any more.
*
* @param checkpointId The ID of the checkpoint that has been completed.
* @throws Exception
*/
void notifyCheckpointComplete(long checkpointId) throws Exception;
}
