技术教程

Kafka Connect 与 Debezium MySQL CDC 实战

--- title: Kafka Connect 与 Debezium MySQL CDC 实战 keywords: - Kafka Connect - Debezium - MySQL CDC - Binlog - Connector description: 使用 Debezium 在 Kafka Connect 中捕获 MySQL 变更,提供 Connector 配置与主题命名规范,适合增量...

Kafka Streams Exactly-Once 处理语义实践

--- title: Kafka Streams Exactly-Once 处理语义实践 keywords: - Kafka Streams - Exactly Once - EOSv2 - processing.guarantee - 事务 description: 在 Kafka Streams 中启用 Exactly-Once v2,提供配置与示例代码,保障端到端处理一致性。 tags: -...

Kafka消费与回压治理实践

--- title: Kafka消费与回压治理实践 keywords: - Kafka - 消费者组 - 回压 - 重平衡 - max.poll.interval.ms - max.poll.records - acks - linger.ms - Idempotent Producer - 有序性 description: 通过合理的消费者参数与限速/回压治理,稳定处理高吞吐消息流,并给出生产者...

Kyverno与Gatekeeper:策略引擎选型

--- title: Kyverno与Gatekeeper:策略引擎选型 keywords: - Kyverno - Gatekeeper - 策略引擎 - 准入控制 - 策略即代码 description: 对比两大 Kubernetes 策略引擎在语法与生态上的差异,指导准入控制与策略治理选型。 categories: - 文章资讯 - 技术教程 --- # Kyverno与Gatek...

NATS JetStream 持久消费者与 Ack 重试策略实战

--- title: NATS JetStream 持久消费者与 Ack 重试策略实战 keywords: JetStream, durable, pull consumer, manualAck, ack policy, max-deliver description: 使用 JetStream 创建流与持久消费者,示例包含手动确认与最大投递次数,确保可靠处理与重试。 categories: ...

NATS JetStream保留与流治理

--- title: NATS JetStream保留与流治理 keywords: - JetStream - Retention - Stream - Consumer - replicas description: 通过 JetStream 的保留策略与流/消费者配置,控制消息存储与投递保障并实现高可用。 categories: - 文章资讯 - 技术教程 --- # NATS Jet...

OAuth PAR与JAR请求对象签名(请求URI-签名验证)最佳实践

--- title: OAuth PAR与JAR请求对象签名(请求URI/签名验证)最佳实践 keywords: - PAR - JAR - 请求对象 - RS256 - 请求URI description: 通过Pushed Authorization Requests与JWT-secured Authorization Request将授权参数推送并签名,保障授权请求的完整性与可信性。 cat...

KEDA Scalers 队列长度与事件驱动自动伸缩(2025)

# KEDA Scalers 队列长度与事件驱动自动伸缩(2025) ## 一、触发器与指标 - Scaler:RabbitMQ/Kafka/Redis 等触发器读取 `队列长度` 与速率。 - 指标:转换为 HPA 可消费的指标,驱动副本数变化。 ## 二、伸缩策略与并发 - 策略:设定最小/最大副本与步进;避免抖动。 - 并发上限:为下游设置并发闸门;防止过度扩张。 - 滞留治理:观察队列