ECI日志采集对接Kafka

前提条件

• ECI实例和Kafka之间网络互通。

  如果您在阿里云上部署Kafka，建议将Kafka和ECI实例部署在同一VPC下。

• 已完成ECI日志采集的相关配置。具体操作，请参见自定义配置ECI日志采集。

通过日志服务控制台配置

Logtail日志采集支持文件和标准输出两种方式，您可以在日志服务控制台配置flushers插件，将日志导入Kafka。配置文本如下：

"flushers": [
    {
      "detail": {
        "Brokers": [
          "Kafka Broker地址"
        ],
        "Topic": "log"
      },
      "type": "flusher_kafka"
    }
  ]

• 对于标准输出，您可以直接修改Logtail配置，在插件配置中新增flushers插件。如下图所示。

  

• 对于文件采集，您需要在高级选项中启用插件处理开关，然后在插件配置中新增flushers插件。如下图所示。

  

结果验证

配置完成后，您可以看到ECI日志已经被采集到Kafka。例如：如果使用的是阿里云云消息队列 Kafka 版，可以在消息查询页面查询到ECI的日志，如下图所示。