K8S环境快速部署Kafka(K8S外部可访问) (2)

查看服务，发现已经可以通过宿主机IP:32181访问zookeeper了，如下图：

验证kafka服务

找一台电脑安装kafka包，就能通过里面自带的命令远程连接和操作K8S的kafka了：

访问kafka官网： ，刚才确定了scala版本2.11，kafka版本2.0.1，因此下载下图红框中的版本：

2. 下载后解压，进入目录kafka_2.11-2.0.1/bin
3. 查看当前topic：

./kafka-topics.sh --list --zookeeper 192.168.50.135:32181

如下图，空空如也：

4. 创建topic：

./kafka-topics.sh --create --zookeeper 192.168.50.135:32181 --replication-factor 1 --partitions 1 --topic test001

如下图，创建成功后再查看topic终于有内容了：

5. 查看名为test001的topic：

./kafka-topics.sh --describe --zookeeper 192.168.50.135:32181 --topic test001

6. 进入创建消息的交互模式：

./kafka-console-producer.sh --broker-list 192.168.50.135:31090 --topic test001

进入交互模式后，输入任何字符串再输入回车，就会将当前内容作为一条消息发送出去：

7. 再打开一个窗口，执行命令消费消息：

./kafka-console-consumer.sh --bootstrap-server 192.168.50.135:31090 --topic test001 --from-beginning

8. 再打开一个窗口，执行命令查看消费者group：

./kafka-consumer-groups.sh --bootstrap-server 192.168.50.135:31090 --list

如下图可见groupid等于console-consumer-21022

9. 执行命令查看groupid等于console-consumer-21022的消费情况：

./kafka-consumer-groups.sh --group console-consumer-21022 --describe --bootstrap-server 192.168.50.135:31090

如下图所示：

远程连接kafka体验基本功能完毕，查看、收发消息都正常，证明本次部署成功；

kafkacat连接

kafkacat是个客户端工具，我这里是在MacBook Pro上用brew安装的；

我这里K8S服务器IP是192.168.50.135，因此执行此命令查看kafka信息：kafkacat -b 192.168.50.135:31090 -L，如下图，可以看到broker信息，以及topic信息(一个是test001，还有一个是consumer的offset)，把端口换成31091和31092会连接到另外两个broker，也能得到相同信息：

清理资源

本次实战创建了很多资源：rbac、role、serviceaccount、pod、deployment、service，下面的脚本可以将这些资源清理掉(只剩NFS的文件没有被清理掉)：

helm del --purge kafka kubectl delete service zookeeper-nodeport -n kafka-test kubectl delete storageclass managed-nfs-storage kubectl delete deployment nfs-client-provisioner -n kafka-test kubectl delete clusterrolebinding run-nfs-client-provisioner kubectl delete serviceaccount nfs-client-provisioner -n kafka-test kubectl delete role leader-locking-nfs-client-provisioner -n kafka-test kubectl delete rolebinding leader-locking-nfs-client-provisioner -n kafka-test kubectl delete clusterrole nfs-client-provisioner-runner kubectl delete namespace kafka-test

至此，K8S环境部署和验证kafka的实战就完成了，希望能给您提供一些参考；

欢迎关注公众号：程序员欣宸

微信搜索「程序员欣宸」，我是欣宸，期待与您一同畅游Java世界...
https://github.com/zq2599/blog_demos