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

王柳  金牌会员 | 2024-6-19 02:04:30 | 来自手机 | 显示全部楼层 | 阅读模式
打印 上一主题 下一主题

主题 542|帖子 542|积分 1626

apiVersion: v1
kind: Service
metadata:
name: zookeeper-nodeport
namespace: kafka-test
spec:
type: NodePort
ports:


  • port: 2181
nodePort: 32181
selector:
app: zookeeper
release: kafka

  • 执行命令:kubectl apply -f zookeeper-nodeport-svc.yaml
  • 查看服务,发现已经可以通过宿主机IP:32181访问zookeeper了,如下图:

验证kafka服务

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

  • 访问kafka官网:http://kafka.apache.org/downloads ,刚才确定了scala版本2.11,kafka版本2.0.1,因此下载下图红框中的版本:


  • 下载后解压,进入目次kafka_2.11-2.0.1/bin
  • 查看当前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体验基本功能完毕,查看、收发消息都正常,证明本次部署乐成;
自我先容一下,小编13年上海交大毕业,曾经在小公司待过,也去过华为、OPPO等大厂,18年进入阿里一直到现在。
深知大多数Java工程师,想要提升技能,往往是自己探索成长大概是报班学习,但对于培训机构动则几千的学费,着实压力不小。自己不成体系的自学效果低效又漫长,而且极易碰到天花板技术停滞不前!
因此收集整理了一份《2024年Java开发全套学习资料》,初衷也很简单,就是希望能够帮助到想自学提升又不知道该从何学起的朋友,同时减轻大家的负担。



既有适合小白学习的零基础资料,也有适合3年以上履历的小伙伴深入学习提升的进阶课程,基本涵盖了95%以上Java开发知识点,真正体系化!
由于文件比较大,这里只是将部分目次截图出来,每个节点里面都包罗大厂面经、学习笔记、源码讲义、实战项目、解说视频,并且会持续更新!
假如你以为这些内容对你有帮助,可以扫码获取!!(备注Java获取)
最后

权威指南-第一本Docker书

引领完成Docker的安装、部署、管理和扩展,让其经历从测试到生产的整个开发生命周期,深入相识Docker适用于什么场景。并且这本Docker的学习权威指南先容了其组件的基础知识,然后用Docker构建容器和服务来完成各种任务:利用Docker为新项目创建测试环境,演示如何使用持续集成的工作流集成Docker,如何构建应用步调服务和平台,如何使用Docker的API,如何扩展Docker。
总共包罗了:简介、安装Docker、Docker入门、使用Docker镜像和仓库、在测试中使用Docker、使用Docker构建服务、使用Fig编配Docke、使用Docker API、获得帮助和对Docker举行改进等9个章节的知识。




关于阿里内部都在强烈保举使用的“K8S+Docker学习指南”—《深入浅出Kubernetes:理论+实战》、《权威指南-第一本Docker书》,看完之后两个字形容,爱了爱了!
《互联网大厂口试真题解析、进阶开发核心学习笔记、全套解说视频、实战项目源码讲义》点击传送门即可获取!
]
关于阿里内部都在强烈保举使用的“K8S+Docker学习指南”—《深入浅出Kubernetes:理论+实战》、《权威指南-第一本Docker书》,看完之后两个字形容,爱了爱了!
《互联网大厂口试真题解析、进阶开发核心学习笔记、全套解说视频、实战项目源码讲义》点击传送门即可获取!

免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!更多信息从访问主页:qidao123.com:ToB企服之家,中国第一个企服评测及商务社交产业平台。

本帖子中包含更多资源

您需要 登录 才可以下载或查看,没有账号?立即注册

x
回复

使用道具 举报

0 个回复

倒序浏览

快速回复

您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

王柳

金牌会员
这个人很懒什么都没写!

标签云

快速回复 返回顶部 返回列表