ECI日志采集对接Kafka
本文介绍如何将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的日志,如下图所示。
