Fluent Bit向Fluentd转发日志至Loki时的异常问题求助

问题1：Fluentd报告"incoming chunk is broken"错误 #

原因 #

AWS NLB的TCP健康检查会向Fluentd的forward端口（24224）发起空连接，而Fluentd的forward协议并非纯TCP，会将这种空连接识别为无效的日志chunk，从而触发错误。

解决方案 #

• 分离健康检查端口：为Fluentd单独配置HTTP健康检查端点，避免NLB健康检查干扰日志传输：
  在Fluentd配置中添加以下内容：

  <source>
    @type http
    port 9880
    bind 0.0.0.0
  </source>
  <match fluentd.healthcheck>
    @type null
  </match>
  

  然后在AWS NLB的健康检查配置中，将检查端口改为9880，协议设为HTTP，路径填写/。
• 调整Fluentd forward配置（可选）：在forward source中添加allow_keepalive false，减少无效连接的持续，但最彻底的方式仍是分离健康检查端口。

问题2：切换镜像后出现"Unknown output plugin ' loki'"错误 #

原因 #

1. 配置文件中@type后面的loki前存在多余空格，导致Fluentd无法识别插件名称；
2. 配置中使用了中文引号（“”），引发配置解析错误；
3. grafana/fluent-plugin-loki:main为开发分支镜像，可能存在插件未正确集成的问题。

解决方案 #

• 修正配置格式：
  将配置中的@type loki改为@type loki（移除loki前的空格），同时把中文引号替换为英文引号：

  <match **>
    @type loki
    url http://my-loki-url:3100
    extra_labels {"job":"fluentd"}
    <buffer>
      flush_interval 10s
      flush_at_shutdown true
    </buffer>
  </match>
  

• 使用稳定版本镜像：替换为指定版本的稳定镜像，例如grafana/fluent-plugin-loki:v0.3.1，避免main分支的不稳定问题。
• 验证插件存在：进入Pod执行fluent-gem list命令，确认fluent-plugin-loki已正确安装，若未安装可手动执行fluent-gem install fluent-plugin-loki（仅临时调试用，建议优先使用官方预安装镜像）。

内容的提问来源于stack exchange，提问作者OriM