logspout-kafka:Logspout适配器,用于将Docker容器日志写入Kafka主题

时间:2024-06-14 07:39:22
【文件属性】:

文件名称:logspout-kafka:Logspout适配器,用于将Docker容器日志写入Kafka主题

文件大小:5KB

文件格式:ZIP

更新时间:2024-06-14 07:39:22

Go

logspout-kafka 一个适配器,用于将Docker容器日志写入主题。 用法 将container-logs作为Docker容器日志的Kafka主题,我们可以使用logspout 将所有消息定向到Kafka: curl http://container-host:8000/routes -d '{ "adapter": "kafka", "filter_sources": ["stdout" ,"stderr"], "address": "kafka-broker1:9092,kafka-broker2:9092/container-logs" }' 消息模板配置 默认行为是将原始消息路由到Kafka。 该适配器提供了一种机制,用于通过KAFKA_TEMPLATE环境变量自定义模板以包含其他元数据。 Golang的包用于模板化,其中可用于模板化的模型是 。 以下


【文件预览】:
logspout-kafka-master
----.gitignore(22B)
----kafka.go(4KB)
----LICENSE(1KB)
----README.md(3KB)
----kafka_test.go(1KB)

网友评论