2.2.4 使用命令行测试Kafka

至此，已经完成了Kafka集群的搭建。我们来进行一个简单的测试，创建一个Topic主题，并使用Kafka提供的命令工具来发送消息和接收消息。

创建一个名称为“mytopic1”的Topic。

其中，

• --zookeeper：用于指定ZooKeeper的地址，如果是多个ZooKeeper地址可以使用逗号分隔。

• --replication-factor：用于指定分区的副本数。这里我们设置的副本数为2，表示同一个分区有两个副本。

• --partitions：用于指定该Topic包含的分区数。这里我们设置的分区数为3，表示该Topic由三个分区组成。

• --topic：用于指定Topic的名称。

使用下面的命令启动Producer发送消息。

使用下面的命令启动Consumer接收消息。由于Kafka支持的是Topic广播类型的消息，可以多启动几个Consumer，如图2.16所示。

图2.16　测试Kafka的消息发送与接收

这里，我们启动了一个Producer和两个Consumer，并在Producer中发送了一条消息“Hello Kafka”；在两个Consumer中，可以看到这条消息被同时接收到了。

下面列出了一些特殊方式的接收命令。