中间件开发

Kafka Connect JDBC Sink 写入 PostgreSQL 实战

---title: Kafka Connect JDBC Sink 写入 PostgreSQL 实战keywords: JdbcSinkConnector, auto.create, insert.mode, pk.mode, table.name.formatdescription: 配置 JDBC Sink 将 Kafka 主题写入 PostgreSQL,启用自动建表、主键与插入模式,实...

Kafka 架构与消费组最佳实践(2025)

# Kafka 架构与消费组最佳实践(2025)Kafka 以分区与副本实现高吞吐与扩展性。本文聚焦消费组、重平衡与幂等处理的工程要点。## 一、分区与副本- 分区:提升并行度;按键路由保证同键有序。- 副本与 ISR:副本同步与故障容忍,提升可用性。## 二、消费组与重平衡- 消费组:以组为单位进行分区分配与并行消费。- 重平衡:控制会话与心跳参数,降低抖动与分配开销。#

Nginx WAF与ModSecurity规则治理实践

---title: Nginx WAF与ModSecurity规则治理实践keywords:- Nginx WAF- ModSecurity- OWASP CRS- 规则治理- 白名单- 误报处理- 速率限制- 日志审计- 验证- 回滚description: 基于 Nginx 与 ModSecurity(OWASP CRS)构建WAF,进行规则治理与白名单、误报处理与速...

NATS Leaf Nodes与Supercluster路由治理

---title: NATS Leaf Nodes与Supercluster路由治理keywords:- NATS- Leaf Node- Supercluster- 路由- 隔离description: 使用 Leaf Nodes 与 Supercluster 连接多集群与边缘节点,规范路由与隔离策略,构建可靠的消息骨干。categories: - 文章资讯 - 技术教...

Kafka事务与正好一次语义治理

---title: Kafka事务与正好一次语义治理keywords:- Kafka- 事务- 正好一次- Idempotence- read_committeddescription: 通过生产者事务与幂等确保正好一次语义,结合 `read_committed` 与事务性偏移提交,保障处理链无重复与不丢失。tags:- Idempotence- Kafka- read_c...

Kafka KRaft 无 ZooKeeper 集群配置要点

---title: Kafka KRaft 无 ZooKeeper 集群配置要点keywords:- KRaft- controller.quorum.voters- process.roles- node.id- listenersdescription: 在 KRaft 模式下配置 Kafka 集群的控制器与代理角色,提供 server.properties 关键参数说明。t...

Kafka 保留与压缩策略治理(2025)

# Kafka 保留与压缩策略治理(2025)Kafka 的保留与压缩配置影响成本与查询与一致性,需要按业务治理。## 一、保留与分段- retention.ms:控制时间保留与容量规划。- segment.bytes:设定分段大小,平衡文件数量与恢复时长。## 二、压缩与键- cleanup.policy:`delete` 与 `compact` 组合策略。- log com