技术教程

Kafka 架构与消费组最佳实践(2025)

# Kafka 架构与消费组最佳实践(2025) Kafka 以分区与副本实现高吞吐与扩展性。本文聚焦消费组、重平衡与幂等处理的工程要点。 ## 一、分区与副本 - 分区:提升并行度;按键路由保证同键有序。 - 副本与 ISR:副本同步与故障容忍,提升可用性。 ## 二、消费组与重平衡 - 消费组:以组为单位进行分区分配与并行消费。 - 重平衡:控制会话与心跳参数,降低抖动与分配开销。 #

Flink 事件时间与水位线深度实践(2025)

# Flink 事件时间与水位线深度实践(2025) 事件时间驱动窗口是 Flink 的核心能力。本文聚焦乱序与迟到数据的工程实践。 ## 一、事件时间与水位线 - 事件时间:以事件携带时间戳驱动计算,避免处理时间偏差。 - 水位线(Watermark):标示低于某时间的事件基本到齐,推进窗口触发。 ## 二、乱序与迟到数据 - 乱序容忍:设置最大乱序延迟,缓解事件到达无序。 - 迟到处理: