写点什么

Knative 实战:基于 Kafka 实现消息推送

  • 2019-11-11
  • 本文字数:1582 字

    阅读完需:约 5 分钟

Knative 实战:基于 Kafka 实现消息推送

背景

消息队列 for Apache Kafka 是阿里云提供的分布式、高吞吐、可扩展的消息队列服务。消息队列 for Apache Kafka 广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等大数据领域,已成为大数据生态中不可或缺的部分。


结合 Knative 中提供了 KafkaSource 事件源的支持, 可以方便的对接 Kafka 消息服务。


另外也可以安装社区 Kafka 2.0.0 及以上版本使用。

在阿里云上创建 Kafka 实例

创建 Kafka 实例

登录消息队列 Kafka 控制台, 选择【购买实例】。由于当前 Knative 中 Kafka 事件源支持 2.0.0 及以上版本,在阿里云上创建 Kafka 实例需要选择包年包月、专业版本进行购买,购买之后升级到 2.0.0 即可。


部署实例并绑定 VPC

购买完成之后,进行部署,部署时设置 Knative 集群所在的 VPC 即可:


创建 Topic 和 Consumer Group

接下来我们创建 Topic 和消费组。


进入【Topic 管理】,点击 创建 Topic, 这里我们创建名称为 demo 的 topic:



进入【Consumer Group 管理】,点击 创建 Consumer Group, 这里我们创建名称为 demo-consumer 的消费组:


部署 Kafka 数据源

部署 Kafka addon 组件

登录容器服务控制台,进入【Knative 组件管理】,部署 Kafka addon 组件。


创建 KafkaSource 实例

首先创建用于接收事件的服务 event-display:


apiVersion: serving.knative.dev/v1kind: Servicemetadata:  name: event-displayspec:  template:    spec:      containers:      - image: registry.cn-hangzhou.aliyuncs.com/knative-sample/eventing-sources-cmd-event_display:bf45b3eb1e7fc4cb63d6a5a6416cf696295484a7662e0cf9ccdf5c080542c21d
复制代码


接下来创建 KafkaSource:


apiVersion: sources.eventing.knative.dev/v1alpha1kind: KafkaSourcemetadata:  name: alikafka-sourcespec:  consumerGroup: demo-consumer  # Broker URL. Replace this with the URLs for your kafka cluster,  # which is in the format of my-cluster-kafka-bootstrap.my-kafka-namespace:9092.  bootstrapServers: 192.168.0.6x:9092,192.168.0.7x:9092,192.168.0.8x:9092  topics: demo  sink:    apiVersion: serving.knative.dev/v1alpha1    kind: Service    name: event-display
复制代码


说明:


  • bootstrapServers: Kafka VPC 访问地址

  • consumerGroup: 设置消费组

  • topics:设置 Topic


创建完成之后,我们可以查看对应的实例已经运行:


[root@iZ2zeae8wzyq0ypgjowzq2Z ~]# kubectl get podsNAME                                    READY   STATUS    RESTARTS   AGEalikafka-source-k22vz-db44cc7f8-879pj   1/1     Running   0          8h
复制代码

验证

在 Kafka 控制台,选择 topic 发送消息,注意这里的消息格式必须是 json 格式:



我们可以看到已经接收到了发送过来的 Kafka 消息:


[root@iZ2zeae8wzyq0ypgjowzq2Z ~]# kubectl logs event-display-zl6m5-deployment-6bf9596b4f-8psx4 user-container
☁️ CloudEvent: valid ✅Context Attributes, SpecVersion: 0.2 Type: dev.knative.kafka.event Source: /apis/v1/namespaces/default/kafkasources/alikafka-source#demo ID: partition:7/offset:1 Time: 2019-10-18T08:50:32.492Z ContentType: application/json Extensions: key: demoTransport Context, URI: / Host: event-display.default.svc.cluster.local Method: POSTData, { "key": "test" }
复制代码

小结

结合阿里云 Kafka 产品,通过事件驱动触发服务(函数)执行,是不是简单又高效?


这样我们利用 Knative 得以把云原生的能力充分释放出来,带给我们更多的想象空间。欢迎对 Knative 感兴趣的一起交流。


实操视频演示


00:00 / 00:00
    1.0x
    • 3.0x
    • 2.5x
    • 2.0x
    • 1.5x
    • 1.25x
    • 1.0x
    • 0.75x
    • 0.5x
    网页全屏
    全屏
    00:00


    作者介绍


    元毅,阿里云容器平台高级开发工程师,负责阿里云容器平台 Knative 相关工作。


    本文转载自公众号阿里巴巴云原生(ID:Alicloudnative)


    原文链接


    https://mp.weixin.qq.com/s/YRpxBNcKlWXdRuMrYaAzig


    2019-11-11 08:002743

    评论

    发布
    暂无评论
    发现更多内容

    产品资讯 | mPaaS 适配 targetSdkVersion 29

    蚂蚁集团移动开发平台 mPaaS

    移动开发 mPaaS

    区块链将与人工智能、物联网、云计算技术形成互补

    CECBC

    人工智能 物联网

    人少钱少需求多的新项目该怎么带?看到这篇我心里有底了!

    华为云开发者联盟

    技术 运维 后端

    花费6个月的时间,五面阿里java岗,最后竟然差点倒在最后HR面?

    Java架构追梦

    Java 学习 编程 架构 面试

    【Java面试官】我管你什么P7、P8?答不出这十道题你就是渣!

    Java架构师迁哥

    阿里P8大牛2020年总结整理的心血之作:17W字操作系统、网络协议教程、面试真题(附导图+笔记)

    Java架构之路

    Java 程序员 架构 面试 编程语言

    【JSRC小课堂】Web安全专题(四)SRC漏洞挖掘技术之命令执行漏洞

    京东科技开发者

    WEB安全

    首个通用安全技术行业标准发布适用于区块链技术架构 但监管仍待完善

    CECBC

    金融 安全技术

    “绝影”机器狗如何利用ModelArts强化学习算法更改导航轨迹

    华为云开发者联盟

    人工智能 机器狗 导航

    训练营第二周作业

    大脸猫

    极客大学架构师训练营

    架构师训练营 -week06-总结

    大刘

    极客大学架构师训练营

    架构师训练营 - 第 6 周课后作业(1 期)

    Pudding

    接口工具使用对比(apipost、jmeter、postman、swagger等)

    测试人生路

    Jmeter Postman 接口测试

    十个写代码的小技巧,保你在面试过程中脱颖而出

    Java架构师迁哥

    苏州高铁新城打造区块链发展聚集地

    CECBC

    区块链 智能合约 金融

    作为打工人,如何正确的选择自动化测试工具(完全指南)

    软测小生

    软件测试 测试 软件自动化测试 测试工具 测试开发

    2020年了,终于有大佬把Java程序员必学知识点总结整理出来了!

    Java架构之路

    Java 程序员 架构 面试 编程语言

    阿里技术四面+交叉面+HR面成功拿到offer,谁说双非本科进不了大厂?

    Java架构之路

    Java 程序员 架构 面试 编程语言

    Java-技术专题-JDK8新特性之Stream流

    码界西柚

    架构师训练营第二周作业

    李日盛

    架构

    技术实践丨PostgreSQL插件之pg_dirtyread "闪回查询"

    华为云开发者联盟

    数据库 后端

    训练营第二周总结

    大脸猫

    极客大学架构师训练营

    一周信创舆情观察(10.19~10.25)

    统小信uos

    打破内卷化,AppGallery Connect的全生命周期赋能方案

    脑极体

    第2周 框架设计-作业

    SuGeek

    Java-技术专题-Stream流详解

    码界西柚

    Appium常用操作之「元素定位、swipe 滑屏操作」

    清菡软件测试

    架构训练营 - 第6周课后作业 - 学习总结

    Pudding

    年末成功上岸腾讯T3-2,全凭这份业内跪求的Java核心笔记

    小Q

    Java 学习 架构 面试 程序猿

    2020中国系统架构师大会活动回顾:ZEGO实时音视频服务架构实践

    ZEGO即构

    架构设计 RTC

    C 语言实现一个简单的 web 服务器

    C语言与CPP编程

    c c++ socket C语言 HTTP

    Knative 实战:基于 Kafka 实现消息推送_语言 & 开发_阿里云容器平台_InfoQ精选文章