启动使用FLume从kafka采集数据写入HDFS代理中文乱码

对于中文乱码问题，可以尝试以下几种方法：

1. 在Flume的配置文件中设置编码格式，例如：

   agent.sources.kafka-source.interceptors = i1
   agent.sources.kafka-source.interceptors.i1.type = regex_extractor
   agent.sources.kafka-source.interceptors.i1.regex = (.*)\\t(.*)
   agent.sources.kafka-source.interceptors.i1.serializers = s1 s2
   agent.sources.kafka-source.interceptors.i1.serializers.s1.name = text1
   agent.sources.kafka-source.interceptors.i1.serializers.s1.type = org.apache.flume.interceptor.RegexExtractorInterceptor$TimestampSerializer
   agent.sources.kafka-source.interceptors.i1.serializers.s2.name = text2
   agent.sources.kafka-source.interceptors.i1.serializers.s2.type = org.apache.flume.interceptor.RegexExtractorInterceptor$TextSerializer
   agent.sources.kafka-source.interceptors.i1.serializers.s2.charset = UTF-8 # 设置编码格式为 UTF-8

2. 在Flume的启动脚本中设置环境变量，例如：

   export JAVA_TOOL_OPTIONS="-Dfile.encoding=UTF-8"

3. 如果以上两种方法都不起作用，可以尝试在Flume的配置文件中使用自定义的拦截器，对消息进行编码转换，例如：

   agent.sources.kafka-source.interceptors = i1
   agent.sources.kafka-source.interceptors.i1.type = com.example.flume.interceptor.EncodingInterceptor
   agent.sources.kafka-source.interceptors.i1.encoding = UTF-8

其中，`com.example.flume.interceptor.EncodingInterceptor` 是自定义的拦截器类，用于将消息从指定的编码格式转换为 UTF-8。