如何从kafka群集中删除Kafka经纪人计算机

问题描述

我们有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经纪人机器都包含以下服务

Kafka broker
Zookeeper server
Schema registry

现在我们要从当前的Kafka集群中删除2 Kafka个代理计算机(我们要删除的Kafka计算机为– 06/07(Kafka版本– 0.1X,)

因此群集最终应该与:

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

3 zookeeper上安装的

kafka01,kafka03服务器/服务

5 schema registry上安装的

kafka01,kafka05服务

当我们从集群中删除Kafka代理-kafka 07/06

时,我们不确定应该更改的Kafka代理中的配置文件到底是什么?

我很高兴收到有关Kafka经纪人删除程序的评论/说明

根据我的理解,我们需要执行以下操作才能删除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服务。

然后从生产者和消费者中的引导服务器中删除主机。

相关问答

错误1:Request method ‘DELETE‘ not supported 错误还原:...
错误1:启动docker镜像时报错:Error response from daemon:...
错误1:private field ‘xxx‘ is never assigned 按Alt...
报错如下,通过源不能下载,最后警告pip需升级版本 Requirem...