kafka集群安装后的命令测试

曾经终败给现在 2022-05-11 13:04 98阅读 0赞

转载 [https://www.cnblogs.com/younldeace/p/3796580.html][https_www.cnblogs.com_younldeace_p_3796580.html]

在129上启动zookeeper服务器

<table> 
 <tbody> 
  <tr> 
   <td> <p>1</p> </td> 
   <td> <p><code>bin/zkServer.sh start conf/zoo.cfg</code></p> </td> 
  </tr> 
 </tbody> 
</table>

启动129，132，133上的kafka服务

<table> 
 <tbody> 
  <tr> 
   <td> <p>1</p> </td> 
   <td> <p><code>[root@bogon kafka_2.8.0-0.8.1]# nohup bin/kafka-server-start.sh config/server.properties &amp;</code></p> </td> 
  </tr> 
 </tbody> 
</table>

在任意机器上建一个topic，因为有三个kafka服务，所以这里replication-factor设为3

<table> 
 <tbody> 
  <tr> 
   <td> <p>1</p> <p>2</p> </td> 
   <td> <p><code>bin/kafka-topics.sh --create --zookeeper 192.168.128.129:2181 --replication-factor 3 -partitions 1 --topic 3test</code></p> <p><code>Created topic "3test".</code></p> </td> 
  </tr> 
 </tbody> 
</table>

查看topic，此时的leader kafka为129，repicas：集群里有三个kafka，Isr：正常使用的kafka

<table> 
 <tbody> 
  <tr> 
   <td> <p>1</p> <p>2</p> <p>3</p> </td> 
   <td> <p><code>bin/kafka-topics.sh --describe --zookeeper 192.168.128.129:2181</code></p> <p><code>Topic:3test PartitionCount:1&nbsp;&nbsp;&nbsp; ReplicationFactor:3 Configs:</code></p> <p><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Topic: 3test&nbsp;&nbsp;&nbsp; Partition: 0&nbsp;&nbsp;&nbsp; Leader: 129 Replicas: 129,132,133&nbsp;&nbsp; Isr: 129,132,133</code></p> </td> 
  </tr> 
 </tbody> 
</table>

在133这台机器上开启一个producer，往132这个kafka发消息

<table> 
 <tbody> 
  <tr> 
   <td> <p>1</p> <p>2</p> <p>3</p> </td> 
   <td> <p><code>[root@slave-03 kafka_2.8.0-0.8.1]# bin/kafka-console-producer.sh --broker-list 192.168.128.132:9092 --topic 3test</code></p> <p><code>this is a message to 132 broker</code></p> <p><code>re?</code></p> </td> 
  </tr> 
 </tbody> 
</table>

停掉132的kafka，再次查看topics，此时可用的Isr为129和133，leader依然为129，因为129的kafka没有被停过，所以没有重新选举leader

<table> 
 <tbody> 
  <tr> 
   <td> <p>1</p> <p>2</p> <p>3</p> </td> 
   <td> <p><code>[root@slave-02 kafka_2.8.0-0.8.1]# bin/kafka-topics.sh --describe --zookeeper 192.168.128.129:2181</code></p> <p><code>Topic:3test PartitionCount:1&nbsp;&nbsp;&nbsp; ReplicationFactor:3 Configs:</code></p> <p><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Topic: 3test&nbsp;&nbsp;&nbsp; Partition: 0&nbsp;&nbsp;&nbsp; Leader: 129 Replicas: 129,132,133&nbsp;&nbsp; Isr: 129,133</code></p> </td> 
  </tr> 
 </tbody> 
</table>

在129上开启一个consumer

<table> 
 <tbody> 
  <tr> 
   <td> <p>1</p> <p>2</p> <p>3</p> </td> 
   <td> <p><code>[root@bogon kafka_2.8.0-0.8.1]# bin/kafka-console-consumer.sh --zookeeper 192.168.128.129:2181 --topic 3test --from-beginning</code></p> <p><code>this is a message to 132 broker</code></p> <p><code>re?</code></p> </td> 
  </tr> 
 </tbody> 
</table>

自此，发现停掉了132，依然能通过zookeeper从129和133的kafka上收到发往132的消息。

kafka集群测试通过

[https_www.cnblogs.com_younldeace_p_3796580.html]: https://www.cnblogs.com/younldeace/p/3796580.html