kafka
Kafka Connect 与 Debezium MySQL CDC 实战
"使用 Debezium 在 Kafka Connect 中捕获 MySQL 变更,提供 Connector 配置与主题命名规范,适合增量数据管道。"
Kafka事务与幂等生产者:Exactly-Once实践
利用幂等生产者与事务实现端到端的 Exactly-Once 语义,降低重复与丢失风险。
Kafka Connect SMT:数据清洗与标准化
使用 Kafka Connect 的 SMT 在管道中进行字段重命名、过滤与规范化,降低下游适配成本。
Kafka消费者重平衡与分配策略:Sticky/Range/RoundRobin
理解消费者组的重平衡机制与三种分配策略的差异,优化分区分配与稳定性。
Kafka Streams状态存储与RocksDB调优
掌握 Kafka Streams 的状态存储与恢复机制,调优 RocksDB/缓存与日志,提升稳定性与延迟表现。
Kafka Schema Registry与兼容策略实践
使用Schema Registry治理消息模式并设置兼容策略,提供可验证的API与CLI示例,保障演进稳定与下游兼容。
Kafka生产者参数调优:acks/linger/batch/compression
调优生产者的确认与批量与压缩参数,平衡吞吐与延迟与可靠性,提升写入效率与稳定性。
