如何从kafka集群中删除Kafka代理机器

How to delete Kafka brokers machines from kafka cluster

我们有 Kafka 集群,集群包括 7 个 Kafka 代理,

版本详情:

Kafka machines are installed on rhel version 7.2 
Kafka version is 0.1x
Zookeeper version: 3.4.10
schema-registry version: 4.0.0

每台 Kafka broker 机器包含以下服务

Kafka broker
Zookeeper server
Schema registry

现在我们要从当前的Kafka集群中删除2 Kafka台brokers机器(我们要删除的Kafka机器是-06/07(Kafka版本-0.1X,)

所以集群最终应该是:

5 Kafka 经纪人机器 - kafka01, kafka02 , kafka03 , kafka04 , kakfa05 , kafka05

3 zookeeper servers/services 安装在 kafka01, kafka02 , kafka03

5 schema registry 安装在 kafka01, kafka02 , kafka03 , kakfa05 , kafka05

上的服务

当我们从集群中删除 Kafka 代理时,我们不确定 Kafka 代理中应该更改的配置文件究竟是什么 - kafka 07/06

我很乐意 remarks/notes 关于 Kafka brokers 删除程序

根据我的理解,我们需要执行以下操作才能删除 kafka 机器 - kafka 06/07

kafka06/07

停止

的服务
Kafka broker
Zookeeper server
Schema registry

然后关闭 kafka06/07 台机器作为

init 0

然后在 kafka01/02/03/04/05

重新启动以下服务
Kafka broker
Zookeeper server
Schema registry

要删除 Kafka Broker 组件,请首先使用 kafka-reassign-partitions.sh 脚本从 Kafka Broker 中识别并重新分配您要停用的 Kafka 主题分区领导者,然后关闭 Kafka Broker服务。

并从生产者和消费者中的 bootstrap-servers 中删除主机。