1、创建Topic，连接的zookeeper是2181，名字取为songshu-topic 命令：bin/kafka-topics.sh --create –zookeeper app-11:2181 app-12:2181 app-13:2181 --replication-factor 1 --partitions 1 --topic songshu-topic 在这里插入图片描述

2、查看Topic 命令：bin/kafka-topics.sh --list --zookeeper app-11:2181 app-12:2181 app-13:2181 在这里插入图片描述

3、发送消息 命令：bin/kafka-console-producer.sh --broker-list app-11:9092 app-12:9092 app-13:9092--topic songshu-topic 发送消息内容：HelloWord、123、003（发送的内容可自定义） 注：当输入命令之后，会出现小箭头，在箭头之后输入需要发送的消息 在这里插入图片描述

4、新建一个new terminal，以hadoop用户登录，在进入到kafka目录下 命令：su – hadoop、cd /hadoop/Kafka/kafka_2.11-2.2.0 在这里插入图片描述

5、接受消息 命令：bin/kafka-console-consumer.sh --bootstrap-server app-11:9092 app-12:9092 app-13:9092 --topic songshu-topic --from-beginning 注：打印的信息和发送的内容是一样的 在这里插入图片描述

6、返回之前的发送命令下，继续输入一个内容 命令：abc 在这里插入图片描述

7、在返回接收的命令下，会实时接收到信息 在这里插入图片描述 详细学习内容可观看Spark快速大数据处理扫一扫~~~或者引擎搜索Spark余海峰 在这里插入图片描述