10年積累的成都網(wǎng)站制作、網(wǎng)站設(shè)計、外貿(mào)網(wǎng)站建設(shè)經(jīng)驗，可以快速應(yīng)對客戶對網(wǎng)站的新想法和需求。提供各種問題對應(yīng)的解決方案。讓選擇我們的客戶得到更好、更有力的網(wǎng)絡(luò)服務(wù)。我雖然不認識你，你也不認識我。但先網(wǎng)站設(shè)計后付款的網(wǎng)站建設(shè)流程，更有玉環(huán)免費網(wǎng)站建設(shè)讓你可以放心的選擇與我們合作。

作者 |?元毅?阿里云智能事業(yè)群高級開發(fā)工程師

導(dǎo)讀：當前在 Knative 中已經(jīng)提供了對 Kafka 事件源的支持，那么如何基于 Kafka 實現(xiàn)消息推送呢？本文作者將以阿里云 Kafka 產(chǎn)品為例，給大家解鎖這一新的姿勢。

背景

消息隊列 for Apache Kafka 是阿里云提供的分布式、高吞吐、可擴展的消息隊列服務(wù)。消息隊列 for Apache Kafka 廣泛用于日志收集、監(jiān)控數(shù)據(jù)聚合、流式數(shù)據(jù)處理、在線和離線分析等大數(shù)據(jù)領(lǐng)域，已成為大數(shù)據(jù)生態(tài)中不可或缺的部分。

結(jié)合 Knative ?中提供了 KafkaSource 事件源的支持， 可以方便的對接 Kafka 消息服務(wù)。

另外也可以安裝社區(qū) Kafka 2.0.0 及以上版本使用。

在阿里云上創(chuàng)建 Kafka 實例

創(chuàng)建 Kafka 實例

登錄消息隊列 Kafka 控制臺, 選擇【購買實例】。由于當前 Knative 中 Kafka 事件源支持 2.0.0 及以上版本，在阿里云上創(chuàng)建 Kafka 實例需要選擇包年包月、專業(yè)版本進行購買，購買之后升級到 2.0.0 即可。

部署實例并綁定 VPC

購買完成之后，進行部署，部署時設(shè)置 Knative 集群所在的 VPC 即可：

創(chuàng)建 Topic 和 Consumer Group

接下來我們創(chuàng)建 Topic 和消費組。
進入【Topic 管理】，點擊?創(chuàng)建 Topic, 這里我們創(chuàng)建名稱為 demo 的 topic:

進入【Consumer Group 管理】,點擊?創(chuàng)建 Consumer Group, 這里我們創(chuàng)建名稱為 demo-consumer 的消費組:

部署 Kafka 數(shù)據(jù)源

部署 Kafka addon 組件

登錄容器服務(wù)控制臺，進入【Knative 組件管理】，部署 Kafka addon 組件。

創(chuàng)建 KafkaSource 實例

首先創(chuàng)建用于接收事件的服務(wù) event-display:

apiVersion: serving.knative.dev/v1
kind: Service
metadata:
  name: event-display
spec:
  template:
    spec:
      containers:
      - image: registry.cn-hangzhou.aliyuncs.com/knative-sample/eventing-sources-cmd-event_display:bf45b3eb1e7fc4cb63d6a5a6416cf696295484a7662e0cf9ccdf5c080542c21d

接下來創(chuàng)建 KafkaSource：

apiVersion: sources.eventing.knative.dev/v1alpha1
kind: KafkaSource
metadata:
  name: alikafka-source
spec:
  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： 設(shè)置消費組
• topics：設(shè)置 Topic

創(chuàng)建完成之后，我們可以查看對應(yīng)的實例已經(jīng)運行：

[root@iZ2zeae8wzyq0ypgjowzq2Z ~]# kubectl get pods
NAME                                    READY   STATUS    RESTARTS   AGE
alikafka-source-k22vz-db44cc7f8-879pj   1/1     Running   0          8h

驗證

在 Kafka 控制臺，選擇 topic 發(fā)送消息，注意這里的消息格式必須是 json 格式：

我們可以看到已經(jīng)接收到了發(fā)送過來的 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: demo
Transport Context,
  URI: /
  Host: event-display.default.svc.cluster.local
  Method: POST
Data,
  {
    "key": "test"
  }

小結(jié)

結(jié)合阿里云 Kafka 產(chǎn)品，通過事件驅(qū)動觸發(fā)服務(wù)（函數(shù)）執(zhí)行，是不是簡單又高效。這樣我們利用 Knative 得以把云原生的能力充分釋放出來，帶給我們更多的想象空間。歡迎對 Knative 感興趣的一起交流。

實操視頻演示鏈接：https://v.qq.com/x/page/d3013wzs3tp.html

作者簡介：元毅，阿里云容器平臺高級開發(fā)工程師，負責阿里云容器平臺 Knative 相關(guān)工作。

“ 阿里巴巴云×××icloudnative×××erverless、容器、Service Mesh等技術(shù)領(lǐng)域、聚焦云原生流行技術(shù)趨勢、云原生大規(guī)模的落地實踐，做最懂云原生開發(fā)×××

另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)cdcxhl.cn，海內(nèi)外云服務(wù)器15元起步，三天無理由+7*72小時售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國服務(wù)器、虛擬主機、免備案服務(wù)器”等云主機租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡單易用、服務(wù)可用性高、性價比高”等特點與優(yōu)勢，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場景需求。

當前文章：Knative實戰(zhàn)：基于Kafka實現(xiàn)消息推送-創(chuàng)新互聯(lián)
標題鏈接：http://weahome.cn/article/eccjd.html