spring boot学习(5)

在服务器安装的时候安装在了/opt 的下面，opt目录下一般用来安装第三方软件，在/usr/local中一般用来放置用户自己的代码
在服务端安装zookeeper
查看进程--方法：ps -aux | grep 'zookeeper'
系统有返回，说明zookeeper启动。
https://yq.aliyun.com/articles/662422
安装完zookeeper后安装kafka

yum remove wget
rpm -qa|grep wget
yum install wget
rpm -qa|grep wget

安装kafka的时候总是显示没有wget命令，但是查看是有的，对于这种情况，先把原来的wget删除，然后重新安装。

参照网址中的地址，发现wget后面的地址无效了，就进入官网http://kafka.apache.org/downloads中选择你要下载的tgz文件复制链接，贴到wget后面进行下载。

kafka的安装后的测试参照
https://cloud.tencent.com/developer/article/1474255

当前位置是在kafka的目录下，在同级目录下有kafkaStart.sh，kafkaStop.sh
首先启动zookeeper

sh /opt/zookeeper/zookeeper-3.4.14/bin/zkServer.sh start

启动kafka

./kafkaStart.sh

创建topic 出现Created topid test 则创建成功

命令：在kafka 目录下bin目录下执行：
./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test  test是topic名字可以随便换哦。

查询创建的top主题 出现test则为正常(我因为原来创建了一个这个是test1)

image.png

下面的命令可以看自己创建的topic

命令：在kafka 目录下bin目录下执行：
./kafka-topics.sh --list --zookeeper localhost:2181

image.png

删除topic

命令：在kafka 目录下bin目录下执行：
./kafka-topics.sh --delete --zookeeper localhost:2181 --topic test1   要删除的topic名称

image.png

测试生成者（test topic）：

命令：在kafka 目录下bin目录下执行：
./kafka-console-producer.sh --broker-list localhost:9092 --topic test（要启动生成者的topic名称）

image.png

测试消费者（test topic）

命令：在kafka 目录下bin目录下执行：
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test（要启动生成者的topic名称）

生产者没生产一个消息，在消费者窗口就会添加一条。
关闭kafka，先关闭kafka再关闭zookeeper，如果kafka没有关闭就关闭了zookeeper就会报错

./kafkaStop.sh

 sh /opt/zookeeper/zookeeper-3.4.14/bin/zkServer.sh stop

image.png

我关闭以后一直报上面的错，然后查看kafka进程是否关闭

ps -ef|grep kafka

发现kafka没有关闭，重新关闭

kill -9 12225 #12225是kafka的进程的PID

以上就是kafka在服务器端的安装与测试