0x01 启动报错 1.1 第一种错误 解决方法：Failed to acquire lock on file .lock in /var/log/kafka-logs.--问题原因 ...

0x00 概述 kafka将topic分成不同的partitions，每个partition的日志分成不同的segments，最后以segment为单位将陈旧的日志从文件系统删除。 假设kafka ...

0x00 概述 本文主要讲Kafka自身操作日志的清理方法(非Topic数据)，Topic数据自己有对应的删除策略，请看这里。 Kafka长时间运行过程中，在kafka/logs目录下产生了大量的 ...

最近公司用到大数据采集系统，用到了api + Kafka+elasticsearch 这三部分构成 ａｐｉ　：采集用户的数据 kafka　：消息订阅系统， elasticsearch ...

0x00 下载 http://www.confluent.io/download，打开后，显示最新版本3.0.0,然后在右边填写信息后，点击Download下载。 之后跳 ...

0x00 概述 filebeat非常轻量级，正常情况下占用的资源几乎都能忽略不计，但是部署后发现资源占用很大，所以怀疑是filebeat本身出了问题。 第一时间查看filebeat日志（默认路径/ ...