打算构建全链路日志系统,由filebeat采集数据,投递到kafka,再由logstash接收后传输到es中,但在配置filebeat的output如下时,启动错误了

报错信息如下:

 

原因是因为:

filebeat的kafka版本库里没有改0.10.1.1的版本,把版本号修改成0.8.2.0即可

Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐