1 zookeeper必备知识 zk的整体结构很像java中的数，zk的单个节点很像java中的接待，也就是一个Node由value值和nexts指针构成；也就是ls /作为根节点，其它节点都派生于此ls时用于查看目录结构的命令，比如 ls / 该命令就是查看根目录下的子目录

1.副本同步线程挂掉，出现副本缺失；重启broker服务，拉起同步线程； 2.Java NIO java.lang.OutOfMemoryError: Direct buffer memory ; Kafka java.lang.OutOfMemoryError: Direct buffer memory总结如下： 1.目前我们Kafka生产集群未配置XX:M

#机架信息 broker.rack=rack-75 #开启安全认证相关 listeners=SASL_PLAINTEXT://xxx:9092 security.inter.broker.protocol=SASL_PLAINTEXT sasl.mechanism.inter.broker.protocol=SCRAM-SHA-256 sasl.enabled.mechanisms=SCRAM-SHA-256 allow.everyone.i

前提：kafka作为分布式消息的一款中间件，安装过程比较复杂，这里记录一下。它依赖zk作为协调服务，所以不会装zk的，请移步上一篇文章吧！ 下面是详细的步骤！ 1、找到压缩包，名称为kafka_2.10-0.10.2.0.tgz 2、上传到ewa

一、 安装 kafkacat 是基于kafka C语言的librdkafka库的 kafka客户端，不依赖java，小巧轻便，支持主流系统。在高版本的debain、Ubuntu下可以直接apt-get install kafkacat，maxos下可以用brew install kafkacat也可以自己编译，也是非常简单(

kafka是一个开源的分布式消息队列 他提供可靠的集群容错机制，并保证故障切换时的数据完整性。 无论从性能、可靠性、易用性都强过ActiveMQ（client的API感觉还是不如ActiveMQ好用，文档也没有更新到最新版） 下面简单记录一下安装步骤和常用命令。 1

1. 到官网下载想要的版本。 2. 启动服务 2.1 解压后打开目录kafka_2.12-2.1.0\bin\windows 2.2 打开kafka_2.12-2.1.0\config修改配置文件 将dataDir（zookeeper.properties）和 log.dirs（server.properties）修改为自定义的路径。因为这里设置的是l

Kafka 应对场景：消息持久化、吞吐量是第一要求、状态由客户端维护、必须是分布式的。Kafka 认为 broker 不应该阻塞生产者，高效的磁盘顺序读写能够和网络 IO 一样快，同时依赖现代 OS 文件系统特性，写入持久化文件时并不调用 flush，仅写入

Docker安装Kafka-Manager（docker-compose.yml） 前置条件 请先安装Docker 创建docker-compose.yml # Docker compose to have Zookeeper, Kafka, and Kafka Manager running for development. # Provided by @chris-zenzookeeper:image: confluent/zookeep

kafka启动后，会产生会多日志，经常会将磁盘撑爆。所以kafka日志清理很有必要 log4j.properties 该文件为kafka日志管理的配置文件，位于$KAFKA_HOME/config/log4j.properties 默认该配置文件中日志存放路径为$KAFKA_HOME/logs，可以修改为其他容量较