kafka生产案例 Kafka有哪些好的例子可以用来快速入门？
Kafka有哪些好的例子可以用来快速入门？
首先用脚本创建销售表，因为它在整个实例中使用。使用sbgocreate table sales（saleid int identity（1,1）、saledate smartdate time、salemount month、itemssold int）go创建消息类型和契约对象，以建立所需的ServiceBroker组件。消息类型对象确认消息的内容，它严格控制会话获得的消息。协定对象指定使用的消息类型对象和会话中消息的方向。Create message type[recordsale]validation=none Create contract[SalesContract]（[recordsale]由发起方发送）go此应用程序将消息从一个service broker队列传输到另一个队列，因此需要建立脚本来实现这些功能。
sql server service broker可以接受kafka的吗？
有两种选择。
Scheme 1 Local message transaction table
生产者需要添加一个事务消息表。具体步骤如下：[1。生产者执行业务逻辑并将事务记录插入到消息表中。这两个操作在一个本地事务中
2。启动后台线程定期轮询消息表并将消息发送到消息队列
3。删除消息表中的消息，直到发送成功。
方案2需要消息队列支持，业务端提供回溯接口
1。生产端将准备好的消息发送到消息队列
2。在本地事务中，业务逻辑
3。根据执行结果确认或取消准备好的消息
4。消息队列将确保准备好的消息被确认或取消，并且消息队列将不断地向生产端请求执行结果，这要求生产端提供类似的回调函数。
在方案2中，消息队列取代了方案1中的消息表和后台线程轮询功能，但并非所有消息队列都支持此功能。支持Rocketmq。
其次，它依赖于少量的外部消息队列开发。
版权声明：本文内容由互联网用户自发贡献，本站不承担相关法律责任.如有侵权/违法内容,本站将立刻删除。
