生产者接收用户的标准输入发送到Kafka，消费者则一直尝试从Kafka中拉取生产的数据，并打印到标准输出中。下面使用Kafka命令行客户端创建主题、生产者与消费者，以测试Kafka集群能否正常使用。

如无特殊说明，以下所有命令都是在Kafka安装目录下执行。

创建主题

创建主题可以使用Kafka提供的命令工具kafka-topics.sh，此处我们创建一个名为topictest的主题，分区数为2，每个分区的副本数为2，命令如下（在Kafka集群的任意节点执行即可）：

$ bin/kafka-topics.sh \

--create \

--bootstrap-server centos01:9092,centos02:9092,centos03:9092 \

--replication-factor 2 \

--partitions 2 \

--topic topictest

上述代码中各参数含义如下。

--create：指定命令的动作是创建主题，使用该命令必须指定--topic参数。
--topic：所创建的主题名称。