义乌做网站要多少钱,大专动漫设计有出路吗,免费软文推广平台,解决方案的网站建设面试官#xff1a;听说你精通Kafka#xff0c;那我就考考你吧 面试官#xff1a;不用慌尽管说#xff0c;错了也没关系#x1f60a;。。。 以【面试官面试】的形式来分享技术#xff0c;本期是《Kafka系列》#xff0c;感兴趣就关注我吧❤️ 面试官#xff1a;生产者重… 面试官听说你精通Kafka那我就考考你吧 面试官不用慌尽管说错了也没关系。。。 以【面试官面试】的形式来分享技术本期是《Kafka系列》感兴趣就关注我吧❤️ 面试官生产者重试机制导致Kafka重复消息知道怎么处理吗
噢噢Kafka支持幂等生产者可以开启这个模块。
它是这样的发送消息时同时发送生产者id、消息序列号kafka会根据这些信息避免重复消息被写入。 面试官思考中… 面试官Kafka事务应该知道吧
嗯嗯知道的消息队列事务主要应用在流式应用程序中。
比如主题A的消息A过来消费者的消费逻辑是发送消息B给主题B。
所以我们要确保消费者成功提交偏移量、新消息成功写入这两步操作要么成功要么都不成功。 面试官思考中… 面试官你说的这个场景不使用事务会有什么问题吗
可能会出现重复消费的问题。
比如消费消息A新消息被成功写入但提交偏移量失败了。Broker会认为该消息未被消费此时消息A会分给其他消费者重复消费。 面试官思考中… 面试官那Kafka事务一般在什么场景下使用呢
我举个例子吧。
例如支付场景下有很多流程步骤用户支付后发送支付消息过来。消费者扣款后还需要发送另一个消息去给商家转账。
这个场景下就需要事务的支持了保证两个步骤的事务性。 面试官抓抓脑袋继续看你的简历… 得想想考点你不懂的 未完待续。。。。。。
好了今天的分享就先到这我们下期【Kafka系列】继续。 创作不易不妨点赞、收藏、关注支持一下各位的支持就是我创作的最大动力❤️
