Ordiy's Blog

使用Curator实现分布式锁核心逻辑使用Apache zookeeper作为分布式协调服务，Apache Curator作为Zookeeper的客户端库来实现分布式锁。通过Curator的InterProcessMutex类，可以轻松地创建和管理分布式锁。 12345678910111213141516boolean acquired == distLock.acquire(lockAw...

通过对比 AWS CloudFront TSV 日志与 Cloudflare Logpush JSON 的字段结构，总结两大 CDN 延迟日志的接入分析方法，以及 Cloudflare 自带 Geo 富化的优势。

在不停服、不换版本的前提下，通过编辑 systemd 服务文件向 KAFKA_OPTS 注入 disallowed.login.modules 指令推送 JNDI/Kerberos 漏洞的修复方案。

记录在生产环境部署一个基于 Kafka + Redis 的 Flink 风控过滤作业，包括实机参数配置、多条优化规则的设计思路与业务部署实践。

展示如何利用 AWS RDS S3 快照作为全量基线再配合 Debezium Binlog CDC 完成增量结合，通过 ReplicatedReplacingMergeTree 入库，实现大表零干扰迁移。

提供一份可直接运行的 docker-compose.yml，在本地开发环境快速拉起带 Web UI 的 Flink Session Cluster，方便调试 Flink SQL 和 UDF。

将海量 ID 文件用 split 切分后，通过 xargs 并行分发给 clickhouse-client 执行，是一种安全、可控的大批量补丁方法。

展示如何在 ClickHouse 中创建 Kafka Engine 外挂表，通过 INSERT INTO ... SELECT 将已清洗的报表数据写入指定 Kafka Topic。

实验通过 Flink ML 在流处理中执行干扰识别演算，发现严重性能问题后转为离线训练+在线轻量推断分离架构的分析与最终決策。

利用 Nginx 反向代理 + Let's Encrypt SSL + auth_basic 对 Flink UI 、Airflow 等内网 Web 管理界面进行认证防护。