首页 文章

为 KAFKA 设置 multi-broker 群集并尝试杀死 Leader Broker

提问于
浏览 次
1

我正在关注设置 multi-broker 群集的官方 KAFKA 指南。当我们在下面发出的命令运行时我们可以看到这一点：

[cloudera@quickstart kafka_2.11-1.1.0]$ ./bin/kafka-topics.sh --describe -- 
zookeeper localhost:2181 --topic my-replicated-topic
Topic:my-replicated-topic   PartitionCount:1    ReplicationFactor:3 Configs:
     Topic: my-replicated-topic Partition: 0    Leader: 2   Replicas: 2,0,1 Isr: 2,0,1

但是，我想根据指南杀死领导者 Broker - 这是节点 2，但我找不到 pid 以杀死领导者。我只能找到 3 个节点中的 1 个。我错过了什么？

[cloudera@quickstart kafka_2.11-1.1.0]$ ps aux | grep server-1.properties
 cloudera 15203  0.1  0.1 528140 20588 ?        S    04:11   0:10 gedit /home/cloudera/kafka_2.11-1.1.0/config/server-1.properties
 cloudera 20833  0.0  0.0 103312   936 pts/7    S+   05:51   0:00 grep server-1.properties

 [cloudera@quickstart kafka_2.11-1.1.0]$ ps aux | grep server-2.properties
  cloudera 20837  0.0  0.0 103308   912 pts/7    S+   05:51   0:00 grep server-2.properties

我可以找到经纪人 1 而不是经纪人 2。

所以我无法杀死领导者经纪人。

但这里必须有一个转折点。运行 Centos 6 BTW。

提前致谢。

apache-kafka

1 回答

  • 0

    当我们运营经纪人时，我们这样做

    kafka-server-start ../config/server.properties 
//by default the value of brokerid is 0 and port is 9092

Create one more server1.properties with brokerid 1 and port 9093 //given nothing is already running on port 9093 and do

kafka-server-start ../config/server1.properties

    在运行多个代理时，您必须拥有多个 server.properties 配置或文件。在server.properties文件中，您的字段为brokerid，默认情况下为 0，而运行多个时您必须更改 brokerid，因为我们不能拥有 2 个具有相同 brokerid 的代理

    并且在 server.properties 中还有一个字段描述了您的服务器(代理)将在哪个端口运行，默认情况下端口的值为 9092，而在运行其他代理时，您也必须更改端口的值不能让 2 个进程在同一个端口上运行。

    如果你想要一个基于 GUI 的工具来看你的 kafka 集群，我建议你使用 kafka-tool，这将为你提供你的集群的全貌你有多少经纪人你有这些经纪人的属性和你有多少分区经纪人是分区外转的领导者。

    回复于

相关问题