Kafka Streams Exactly-Once v2 事务处理与状态容错实践
配置 Kafka Streams 使用 Exactly-Once v2 事务保障端到端一致性，示例构建拓扑并验证状态容错与重启恢复。
工程实践
Kafka Schema Registry与兼容策略实践
使用Schema Registry治理消息模式并设置兼容策略，提供可验证的API与CLI示例，保障演进稳定与下游兼容。
Kafka Schema Registry 兼容性与模式演进实践
配置全局与主题级兼容性策略，注册 Avro 模式并验证兼容性，安全演进事件结构。
Kafka Producer 幂等与事务写入实践
配置 Kafka Producer 幂等与事务写入，保证端到端一致性与去重；示例展示事务开启、发送与提交流程。
压缩与模式演进治理（2025）
Kafka Connect S3 Sink 分区/压缩与模式演进治理（2025）一、分区与命名分区：按时间/主题/分区生成层级；支持查询按需加载。命名：统一文件名与路径；避免碎片与小文件。二、压缩与格式压缩：使用 `gzip/zstd`；平衡 CPU 与存储成本。格式：Avro/Parquet/JS
Kafka Connect Elasticsearch Sink 连接器写入索引实践
使用 Elasticsearch Sink 连接器将 Kafka 主题写入索引，配置连接与写入模式、键处理与容错策略。
Kafka ACL 与多租户安全实践
"使用 ACL 管理 Kafka 多租户访问权限，示例覆盖用户创建、SCRAM 认证与主题级 ACL 规则。"
Kafka ACL 与 SASL/SCRAM 安全认证配置实践
配置 Kafka 使用 SASL/SCRAM 认证并启用 ACL 授权，通过命令创建用户凭据与精细化访问控制。
K8s PodSecurity 与安全上下文实践（2025）
K8s PodSecurity 与安全上下文实践（2025）Pod 安全依赖准入策略与运行时配置，防止越权与逃逸。一、策略与级别PodSecurity：按 Baseline/Restricted 管控默认策略。准入：在集群层启用策略引擎统一校验。二、安全上下文SecurityContext：`run
