Kafka 不再需要 ZooKeeper

在Kafka早期版本，对于分区和副本的状态的管理依赖于zookeeper的Watcher和队列：每一个broker都会在zookeeper注册Watcher，所以zookeeper就会出现大量的Watcher, 如果宕机的broker上的partition很多比较多，会造成多个Watcher触发，造成集群内

工具简介： kafka-manager的Github项目地址（项目功能等介绍）：https://github.com/yahoo/kafka-manager A tool for managingApache Kafka. It supports the following : Manage multiple clustersEasy inspection of cluster state (topics, consu

本文来说下kafka图形化管理工具kafka-manager kafka图形化界面、 文章目录概述 概述

LogManager主要负责Kafka的Log相关管理 1.LogManager初始化与启动 var logManager: LogManager = null ... //这里省略部分代码逻辑 // logManager = LogManager(config, initialOfflineDirs, zkClient, brokerState, kafkaScheduler, time, brokerTopicStats, logDir

1.说明 Kafka集群安装，基于版本1.0.1， 使用kafka_2.12-1.0.1.tgz安装包， 其中2.12是编译工具Scala的版本。 而且不需要另外安装Zookeeper服务， 使用Kafka自带的Zookeeper即可。 2.安装规划 kafka集群安装部署、Kafka:集群，安装3个Kafka服务

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，可以修改为其他容量较