微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

K8S学习笔记之使用Fluent-bit将容器标准输入和输出的日志发送到Kafka

 

0x00 概述

K8S内部署微服务后,对应的日志方案是不落地方案,即微服务的日志不挂在到本地数据卷,所有的微服务日志都采用标准输入和输出的方式(stdin/stdout/stderr)存放到管道内,容器日志采用的是json格式。

目前大部分K8S容器日志都采用Fluent或者Fluent-bit,将日志传输到ES集群,本文主要讲使用Fluent-bit将容器的日志传输到Kafka。

 

0x01 部署Fluent-bit并传输到Kafka

详细请看https://github.com/fluent/fluent-bit-kubernetes-logging

1.1 创建Fluent-bit Daemonset使用的configmap

$ kubectl create -f https://raw.githubusercontent.com/fluent/fluent-bit-kubernetes-logging/master/output/kafka/fluent-bit-configmap.yaml

1.2 配置Fluent-bit Daemonset将K8S日志传输到Kafka

$ kubectl create -f https://raw.githubusercontent.com/fluent/fluent-bit-kubernetes-logging/master/output/kafka/fluent-bit-ds.yaml

 

0x02 Fluent-bit输出方向ES和Kafka

https://github.com/fluent/fluent-bit-kubernetes-logging/tree/master/output

 

0x03 Fluent-bit将K8S日志传输到Kafka

https://github.com/fluent/fluent-bit-kubernetes-logging/tree/master/output/kafka

 将https://github.com/fluent/fluent-bit-kubernetes-logging/blob/master/output/kafka/fluent-bit-configmap.yaml 文件内的Brokers的value改写成Kafka的IP加9092端口即可。

例如   10.10.11.32:9092

 

0x04 日志格式过滤

关于详细的部署的格式过滤可以参考这篇https://www.jianshu.com/p/1000ae80a493

 

0x05 总结

多参考官方网站和搜刮github,尽量少使用百度,百度搜索几乎无解。。。。

 

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 [email protected] 举报,一经查实,本站将立刻删除。

相关推荐