状态存储治理（2025）

Kafka Streams Exactly-Once 与事务/状态存储治理（2025）一、EOS 与事务配置：启用 `processing.guarantee=exactly_once_v2`；设置事务超时与隔离级别。幂等：生产端使用幂等写；避免重复提交。事务边界：按拓扑节点划分事务；失败回滚与重试策略。二、状态存储与 Changelog状态存储：RocksDB/内存状态存储；设置压缩与缓存参数。Changelog：记录状态变更；副本与保留策略保障恢复。重建：故障后从 Changelog 快速恢复；避免全量回放。三、拓扑与容错拓扑：合理划分分区与并行度；避免热点分区。容错：任务迁移与再均衡；有序关停与滚动升级。四、观测与安全指标：处理延迟、事务失败率、状态存储大小、恢复时长。安全：ACL 与命名空间隔离；审计变更。注意事项关键词（Exactly-Once、事务、状态存储、Changelog、幂等）与正文一致。分类为“数据/消息/Kafka”，不超过三级。参数需在代表性负载与演练中验证。