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,盡量少使用百度,百度搜索幾乎無解。。。。

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM