Ubuntu使用

• 打开Ubuntu虚拟机

• 进入zookeeper安装目录 gb@gb-VMware-Virtual-Platform:~$ cd /usr/apache-zookeeper-3.9.3-bin

• 在终端启动zookeeper服务 gb@gb-VMware-Virtual-Platform:/usr/apache-zookeeper-3.9.3-bin$ sudo bin/zkServer.sh start

• 检查zookeeper进程 gb@gb-VMware-Virtual-Platform:/usr/apache-zookeeper-3.9.3-bin$ ps -ef | grep zookeeper

• 进入kafka安装目录 gb@gb-VMware-Virtual-Platform:/usr/apache-zookeeper-3.9.3-bin$ cd /home/gb/下载/kafka

• 在终端启动kafka服务 gb@gb-VMware-Virtual-Platform:~/下载/kafka$ bin/kafka-server-start.sh config/server.properties

• 另起一个终端（以下在终端输入的代码均在新开的终端中进行）

• 检查kafka进程 gb@gb-VMware-Virtual-Platform:~/下载/kafka$ ps -ef | grep kafka

• 查看topic gb@gb-VMware-Virtual-Platform:~/下载/kafka$ bin/kafka-topics.sh --list --bootstrap-server IP address:9092

• 使用消费者 gb@gb-VMware-Virtual-Platform:~/下载/kafka$ bin/kafka-console-consumer.sh --bootstrap-server IP address:9092 --topic haha --from-beginning

• 打开windows中的kafka assistant

• 在kafka assistant中向虚拟机中发送消息，检查终端是否收到消息

• 退出消费者模式，在终端按Ctrl+C

• 使用生产者 gb@gb-VMware-Virtual-Platform:~/下载/kafka$ bin/kafka-console-producer.sh --broker-list IP address:9092 --topic haha