通过Producer向Topic发送消息

Topic 创建完成之后，测试向当前“firsttopic”消息队列中生产消息。向Kafka 中的Topic 中生产消息的生产者可以多种多样，这些生产者可以是分布式采集工具Flume、Kafka Console 生产者、Java 或者Scala 调用生产者API 所形成的客户端等。无论是以上哪种生产者，都可以生成各种各样的消息输入Kafka 集群中。Kafka 集群的吞吐量可以达到百兆每秒的速度，所以Kafka 的生产者也可以是多生产者并行生产的系统。

下面将Kafka Console 当作消息的生产者，向当前“firsttopic”消息队列中生产消息。可以在Kafka 任意一台Broker 节点上执行向Topic 中生产消息的命令，这里以在mynode1 节点执行生产命令为例，在mynode1 上执行如下生产命令：

对以上执行命令的参数解释如下：

·kafka-console-producer.sh：Console 的生产的脚本。

·--broker-list：Kafka 集群的Broker 节点，这里是执行Kafka 生产者将消息生产到哪个Kafka 集群中。(www.xing528.com)

·--topic：执行生产者生产消息的Topic，也就是将消息写入哪个Topic 中。

以上命令执行完成之后，Kafka Console 就处于等待输入消息的状态。向Kafka 的“firsttopic”中输入如下消息：

通过以上输入命令，向Kafka 的“firsttopic” 中输入了5 条消息，下面检验这5 条消息是否全部成功生产到Kafka 的“firsttopic”中。