写点什么

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:002781

    评论

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

    2025 年软件测试趋势:你准备好了吗?

    FunTester

    【签约快讯|天润融通签约味全】

    天润融通

    片段式代码VS完整工程生成:飞算JavaAI如何让开发者告别碎片化开发?

    飞算JavaAI开发助手

    一天成为Java开发高手:用飞算JavaAI实现十倍提效

    飞算JavaAI开发助手

    YashanDB环境变量

    YashanDB

    数据库 yashandb

    下载量周榜前十,昆仑万维视频生成模型SkyReels-V1开源效果喜人

    新消费日报

    三句话生成 P5.js 粒子特效代码,人人都可以做交互式数字艺术

    阿里云云效

    阿里云 云原生 AI程序员 AI程序员体验官

    明晚见:快速上手 IoTDB 树表双模型,功能/场景直播详解!

    Apache IoTDB

    域名服务器有哪些不同类型?

    伤感汤姆布利柏

    低代码平台:数字化时代的开发加速器与业务创新引擎

    万界星空科技

    低代码 低代码开发 低代码平台 mes 万界星空科技低代码平台

    融云数据监控平台「北极星」教程,聊天室洪峰、连接异常、消息未达正确解法

    融云 RongCloud

    AI生成表单│告别重复劳动,用AI对话生成你的专属业务表单

    引迈信息

    三句话生成 P5.js 粒子特效代码,人人都可以做交互式数字艺术

    阿里巴巴云原生

    阿里云 云原生 通义灵码 AI程序员 AI程序员体验官

    YashanDB用户操作

    YashanDB

    数据库 yashandb

    飞算JavaAI代码生成实战:如何用AI技术减少70%重复编码

    飞算JavaAI开发助手

    商汤“万象”:AI的“超级工具箱”,开发者的新宠儿!

    商汤万象开发者

    AI

    天润融通推出DeepSeek私有化部署方案,助力企业提升服务体验

    天润融通

    AIBrix: 专为 vLLM 打造的可扩展、高性价比控制面

    字节跳动开源

    云原生技术 大模型推理优化 开源AI基础设施 分布式系统架构 企业级AI工程化

    远程办公网络访问优化指南

    Ogcloud

    SD-WAN 企业组网 企业网络 异地组网 远程办公网络

    YashanDB客户端安装

    YashanDB

    数据库 yashandb

    YashanDB实例启停

    YashanDB

    数据库 yashandb

    RocketMQ 可观测性最佳实践

    观测云

    RocketMQ

    小米基于 Apache Paimon 的流式湖仓实践

    Apache Flink

    大数据 flink 实时计算

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