生产环境建议部署$QJM\ (Quorum\ Journal\ Manager)$+$ZooKeeper$方案，JournalNode需独立部署在非NameNode节点，ZooKeeper集群节点数应为奇数（3/5/7）。确保所有节点$Hadoop\ Version$一致： $$ \Delta \text{版本} \leq 0.1.x $$

Flume中KafkaSource到KafkaSink的Topic覆盖问题解决方案：当使用KafkaSource从topicA消费数据并通过KafkaSink发送到topicB时，可能因header中的topic信息导致目标topic被覆盖。解决方法是通过自定义拦截器修改事件header，强制将topic字段设为topicB。实施步骤包括：1）理解问题成因；2）创建自定义拦截器修改header；3