卖逼视频免费看片|狼人就干网中文字慕|成人av影院导航|人妻少妇精品无码专区二区妖婧|亚洲丝袜视频玖玖|一区二区免费中文|日本高清无码一区|国产91无码小说|国产黄片子视频91sese日韩|免费高清无码成人网站入口

kafka生產(chǎn)案例 Kafka有哪些好的例子可以用來快速入門?

Kafka有哪些好的例子可以用來快速入門?首先用腳本創(chuàng)建銷售表,因為它在整個實例中使用。使用sbgocreate table sales(saleid int identity(1,1)、saleda

Kafka有哪些好的例子可以用來快速入門?

首先用腳本創(chuàng)建銷售表,因為它在整個實例中使用。使用sbgocreate table sales(saleid int identity(1,1)、saledate smartdate time、salemount month、itemssold int)go創(chuàng)建消息類型和契約對象,以建立所需的ServiceBroker組件。消息類型對象確認消息的內容,它嚴格控制會話獲得的消息。協(xié)定對象指定使用的消息類型對象和會話中消息的方向。Create message type[recordsale]validation=none Create contract[SalesContract]([recordsale]由發(fā)起方發(fā)送)go此應用程序將消息從一個service broker隊列傳輸?shù)搅硪粋€隊列,因此需要建立腳本來實現(xiàn)這些功能。

sql server service broker可以接受kafka的嗎?

有兩種選擇。

Scheme 1 Local message transaction table

生產(chǎn)者需要添加一個事務消息表。具體步驟如下:[1。生產(chǎn)者執(zhí)行業(yè)務邏輯并將事務記錄插入到消息表中。這兩個操作在一個本地事務中

2。啟動后臺線程定期輪詢消息表并將消息發(fā)送到消息隊列

3。刪除消息表中的消息,直到發(fā)送成功。

方案2需要消息隊列支持,業(yè)務端提供回溯接口

1。生產(chǎn)端將準備好的消息發(fā)送到消息隊列

2。在本地事務中,業(yè)務邏輯

3。根據(jù)執(zhí)行結果確認或取消準備好的消息

4。消息隊列將確保準備好的消息被確認或取消,并且消息隊列將不斷地向生產(chǎn)端請求執(zhí)行結果,這要求生產(chǎn)端提供類似的回調函數(shù)。

在方案2中,消息隊列取代了方案1中的消息表和后臺線程輪詢功能,但并非所有消息隊列都支持此功能。支持Rocketmq。

其次,它依賴于少量的外部消息隊列開發(fā)。