Kafka Connect Elasticsearch Sink 连接器写入索引实践
使用 Elasticsearch Sink 连接器将 Kafka 主题写入索引，配置连接与写入模式、键处理与容错策略。
中间件开发
Kafka Connect SMT：数据清洗与标准化
---title: Kafka Connect SMT：数据清洗与标准化keywords:- SMT- Single Message Transform- 重命名- 过滤- 规范化description: 使用 Kafka Connect 的 SMT 在管道中进行字段重命名、过滤与规范化，降低下游适配成本。tags:- Connect- Kafka- SMT- Singl...
Kafka Connect 与 Debezium MySQL CDC 实战
---title: Kafka Connect 与 Debezium MySQL CDC 实战keywords:- Kafka Connect- Debezium- MySQL CDC- Binlog- Connectordescription: 使用 Debezium 在 Kafka Connect 中捕获 MySQL 变更，提供 Connector 配置与主题命名规范，适合增量...
NATS JetStream 流与持久化订阅实践
---title: NATS JetStream 流与持久化订阅实践keywords:- NATS- JetStream- Stream- Consumer- 持久化订阅description: 使用 NATS JetStream 创建流与消费者，实现持久化订阅与消息确认，适合高可靠实时场景。categories: - 文章资讯 - 技术教程---# NATS Jet...
Kafka事务与Exactly-Once处理实践
---title: Kafka事务与Exactly-Once处理实践keywords:- Kafka- Exactly-Once- 事务- 幂等生产者- read_committed- Streamsdescription: 在Kafka中通过事务与幂等生产者实现Exactly-Once处理，提供可验证的客户端配置与操作命令，保障端到端一致性。date: 2025-11-26...
Kafka延迟与重试退避策略实践
---title: Kafka延迟与重试退避策略实践keywords:- Kafka- 重试- 退避- backoff- 延迟- DLQdescription: 通过生产者/消费者重试与退避策略优化Kafka延迟与稳定性，提供可验证的配置与命令，保障高并发处理。date: 2025-11-26tags:- DLQ- Kafka- backoff- 延迟- 性能- ...
Elasticsearch PIT 与 search_after 深分页稳定查询实践
使用 Point-in-Time 与 search_after 实现深分页稳定查询，避免滚动期间索引变更导致结果漂移。
NATS JetStream保留与流治理
---title: NATS JetStream保留与流治理keywords:- JetStream- Retention- Stream- Consumer- replicasdescription: 通过 JetStream 的保留策略与流/消费者配置，控制消息存储与投递保障并实现高可用。categories: - 文章资讯 - 技术教程---# NATS Jet...
Nginx 双向 TLS(mTLS) 客户端证书校验配置
---title: Nginx 双向 TLS(mTLS) 客户端证书校验配置keywords:- mTLS- 客户端证书- ssl_verify_client- CA 链- OCSPdescription: 在 Nginx 中启用双向 TLS，提供客户端证书校验与必要的安全配置示例。categories: - 文章资讯 - 技术教程---# Nginx 双向 TLS(...
Kafka KRaft与ZooKeeper迁移治理
---title: Kafka KRaft与ZooKeeper迁移治理keywords:- Kafka- KRaft- ZooKeeper- 迁移- 控制面description: 评估并迁移到 KRaft 控制面，理解架构差异与滚动升级策略，降低复杂度与运维成本。tags:- KRaft- Kafka- ZooKeeper- 控制面- 数据- 架构- 迁移cat...
Kafka Schema Registry 兼容性与模式演进实践
配置全局与主题级兼容性策略，注册 Avro 模式并验证兼容性，安全演进事件结构。
Kafka机架感知与副本放置治理
---title: Kafka机架感知与副本放置治理keywords:- Kafka- 机架感知- 副本放置- broker.rack- 容灾description: 配置机架感知与副本放置策略，跨故障域分散副本与领导者，提升容灾与可用性。tags:- Kafka- broker.rack- 副本放置- 容灾- 数据- 机架感知- 高可用categories: ...
Kafka消费与回压治理实践
---title: Kafka消费与回压治理实践keywords:- Kafka- 消费者组- 回压- 重平衡- max.poll.interval.ms- max.poll.records- acks- linger.ms- Idempotent Producer- 有序性description: 通过合理的消费者参数与限速/回压治理，稳定处理高吞吐消息流，并给出生产者...
Nginx Ingress零停机发布与连接保持实践
---title: Nginx Ingress零停机发布与连接保持实践keywords:- Nginx Ingress- 零停机- 连接保持- keepalive- 缓慢启动- upstreamdescription: 通过Nginx Ingress与后端配置连接保持与缓慢启动，提供可验证注解与命令，实现零停机发布与稳定回源。date: 2025-11-26categorie...
