代码之家  ›  专栏  ›  技术社区  ›  Ged

为卡夫卡建立多代理集群并试图杀死领头代理

  •  0
  • Ged  · 技术社区  · 6 年前

    我遵循官方的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
    

    但是,我想按照指南杀死领队代理——这是节点2,但是我找不到PID来杀死领队。我只能找到三个节点中的一个。我错过了什么?

    [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。

    事先谢谢。

    1 回复  |  直到 6 年前
        1
  •  0
  •   Raman Mishra    6 年前

    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,您必须更改代理,因为我们不能有两个具有相同代理的代理

    如果你想让一个基于图形用户界面的工具看到你的kafka集群,我建议你使用kafka工具,它将给你整个集群的图片,你有多少个代理拥有这些代理的属性,你有多少个分区,哪个代理曾经是哪个分区的领导者?叮叮声。