2.6. 使用集群
这个步骤描述了如何启动 Kafka 控制台制作者和消费者客户端，并使用它们发送和接收多个信息。
在第 1 步中自动创建一个新主题。主题自动创建使用 auto.create.topics.enable 配置属性（默认设置为 true ）进行控制。或者，您可以在使用集群前配置和创建主题。如需更多信息，请参阅 主题。
流程
启动 Kafka 控制台制作者并将其配置为发送消息到新主题：
/opt/kafka/bin/kafka-console-producer.sh --broker-list <bootstrap-address> --topic <topic-name>
例如：
/opt/kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic my-topic
在控制台中输入多个消息。按 Enter 将每个单独消息发送到您的新主题：
>message 1 >message 2 >message 3 >message 4
当 Kafka 自动创建一个新主题时，您可能会收到一个表明该主题不存在的警告：
WARN Error while fetching metadata with correlation id 39 : {4-3-16-topic1=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)发送进一步消息后，不应重新显示警告。
在新的终端窗口中，启动 Kafka 控制台使用者并将其配置为从新主题开始时读取消息。
/opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server <bootstrap-address> --topic <topic-name> --from-beginning
例如：
/opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my-topic --from-beginning
传入的消息显示在使用者控制台中。
- 切换到制作者控制台并发送其他消息。检查它们是否显示在使用者控制台中。
- 按 Ctrl+C 停止 Kafka 控制台制作者，再停止使用者。
