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ā)。