Kafka Streams 拓扑测试
系统讲解 Kafka Streams 测试:TopologyTestDriver 初始化与输入输出通道、事件时间推进与窗口断言、状态存储校验、序列化与 Schema 测试、Testcontainers 容器化端到端集成测试、CI 中的测试策略与常见陷阱
tag
系统讲解 Kafka Streams 测试:TopologyTestDriver 初始化与输入输出通道、事件时间推进与窗口断言、状态存储校验、序列化与 Schema 测试、Testcontainers 容器化端到端集成测试、CI 中的测试策略与常见陷阱
深入 Kafka Streams 状态存储:KV 与窗口状态语义、changelog 变更日志与故障恢复、RocksDB 内存与压缩调优、standby 副本加速、再平衡下的状态迁移与本地目录管理、可查询状态、常见故障排查、恢复时间估算与调优清单
系统讲解 ksqlDB 在 Kafka 之上做流式 SQL 处理的完整知识体系:ksqlDB 与 Kafka Streams 的关系与架构分层、STREAM 与 TABLE 的语义差异与 changelog 主键模型、CREATE STREAM 与 WITH 子句的数据映射、Schema Registry 与 Avro 集成、TUMBLING/HOPPING/SESSION 三种窗口与 GRACE PERIOD 宽限期、Push 查询与 Pull 查询的路由与一致性、物化表与持久查询、流表 join 与重分区,以及何时选 ksqlDB 何时回归 Kafka Streams 的取舍对比与生产运维踩坑
Kafka Streams DSL/Processor API、窗口操作、Join、状态存储、KSQL 查询与实时流处理实战