ghcr.io/kube-logging/fluentd-drain-watch:v0.2.4

ghcr.io/kube-logging/fluentd-drain-watch 是 Kube-Logging 社区开发的轻量级辅助工具，专为解决 Kubernetes 集群中节点维护场景下的日志丢失问题设计。作为 Fluentd 日志收集架构的补充组件，它通过主动监控节点状态变化，协调日志收集流程与节点排空操作（drain），确保在节点下线或 Pod 驱逐过程中日志数据完整写入后端存储。

该工具的核心功能集中在三个方面：一是实时监听 Kubernetes 节点事件，重点捕捉节点进入排空状态的信号（如添加 NoSchedule 调度标记）；二是动态调整 Fluentd 运行策略，例如触发日志缓冲区强制刷新、暂停新日志数据转发；三是与节点调度机制联动，通过临时阻止 Pod 驱逐（如添加 Pod 亲和性规则），为日志处理争取必要时间。

其工作原理基于 Kubernetes API 事件驱动模型：当节点开始排空时，工具通过 API Server 感知节点污点变化，随即向运行在该节点的 Fluentd DaemonSet 实例发送控制指令，要求其优先处理缓存中的日志数据。待后端存储确认接收所有缓存日志后，工具自动移除调度限制，允许 kubelet 继续执行 Pod 驱逐流程。

这一工具特别适用于节点升级、硬件故障迁移、集群缩容等需要主动排空节点的运维场景，尤其对***交易、电商订单等依赖完整日志进行审计或问题追溯的业务至关重要。相比传统依赖 Fluentd 自身缓冲超时机制的方案，它通过主动协调将日志丢失风险从分钟级降至秒级，且组件本身仅占用少量集群资源，可直接集成到现有 Fluentd 部署架构中，无需额外改造存储或网络配置。