转载自：http://blog.csdn.net/qq_35246620/article/details/78624256在 Linux 命令中，chmod用于修改文件或者目录的权限。对于文件或者目录的普通权限，共有 3 种，分别为：r：读取；w：写入；x：执行。此外，还有 3 种特殊权限，分别为：suid：Set User ID；sgid：Set Group ID

利用docker compose 搭建es 3节点集群环境

1.helm repo add kaiyuanshe http://mirror.kaiyuanshe.cn/kubernetes/charts/2.helm search repo kafka-manager3.helm fetch kaiyuanshe/kafka-manager4.tar -zxvf kafka-manager-2.3.5.tgz5.kubectl create namesp

慢慢填充K8s 常用命令

利用K8s 搭建ELK 环境

概念Kafka Connect 是一款可扩展并且可靠地在 Apache Kafka 和其他系统之间进行数据传输的工具。 可以很简单的定义 connectors（连接器） 将大量数据迁入、迁出Kafka。逻辑图Kafka Connect 特性如下：Kafka 连接器的通用框架：Kafka Connect 标准化了其他数据系统与Kafka的集成，从而简化了连接器的开发，部署和管理支持分布式模式和单机模

目录Kafka 日志存储结构日志删除日志压缩Kafka 日志存储结构来看一个整体的kafka日志目录结构图：Kafka 将消息存储到磁盘中，随着写入数据不断增加，磁盘占用空间越来越大，为了控制占用空间就需要对消息做一定的清理操作。Kafka 存储日志结构分析中每一个分区副本（Replica）都对应一个 Log，而 Log 又可以分为多个日志分段（LogSegment），这样就便于 Kafka 对日

生产者需要用序列化器（Serializer）把对象转换成字节数组才能通过网络发送给Kafka。而在对侧，消费者需要用反序列化器（Deserializer）把从 Kafka 中收到的字节数组转换成相应的对象。先参考下面代码实现一个简单的客户端。为了方便，消息的 key 和 value 都使用了字符串，对应程序中的序列化器也使用了客户端自带的 org.apache.kafka.common.seria

目录前言控制器选举(Kafka核心总控制器Controller)Controller选举机制Controller防止控制器脑裂机制Kafka Controller控制器的职责Kafka Controller控制器的作用(同上职责)Partition Replicates副本选举机制消费者组选举Kafka协调器参考前言Kafka是一个高性能，多副本，可复制的分布式消息系统。在整个系统中，涉及到多处选

Canal中间件同步MySql数据到ElasticSearch