本次实验k8s中要做日志收集。
具体的流程filebeat => kafka => logstash => es =>Kibana
kafka
1.做了ssl认证配置
2.做了 配置SASL/SCRAM认证
上述kafka做了认证,所以你的filebeat,logstash就必须要做相同的认证。
我用的是ELK8.0的版本
当然你一定要看你的logstash的版本中,你的input和ouput插件中的kafka插件是否支持你的kafka版本,不然你的密钥对接不上。

本次实验k8s中要做日志收集。
具体的流程filebeat => kafka => logstash => es =>Kibana
kafka
1.做了ssl认证配置
2.做了 配置SASL/SCRAM认证
上述kafka做了认证,所以你的filebeat,logstash就必须要做相同的认证。
我用的是ELK8.0的版本
当然你一定要看你的logstash的版本中,你的input和ouput插件中的kafka插件是否支持你的kafka版本,不然你的密钥对接不上。