Kafka Streams状态存储与RocksDB调优

Kafka Streams状态存储与RocksDB调优概览状态存储用于聚合与连接；RocksDB 提供持久层；恢复依赖 changelog 与 checkpoint。调参与监控决定延迟与可靠性。技术参数（已验证）状态商店：`KeyValueStore/WindowStore/SessionStore`；持久化到 RocksDB；缓存层减少写入频率。恢复：通过 changelog 回放与 checkpoint 快速恢复；记录偏移与状态一致性。调优：RocksDB `block_cache`、压缩策略（`lz4/zstd`）、写放大与 compaction；控制文件数与列族配置。记录格式：启用字节序列与序列化；与 Schema Registry 协同。观测：状态大小与恢复时长、compaction/flush 指标；告警与回退。实战清单为大状态任务设置合理缓存与压缩；控制 compaction 带来的抖动。建立恢复与回放基准；在扩缩容与故障时验证一致性。监控状态与changelog吞吐；优化线程与并发参数。