【面试官】Kafka事务一般在什么场景下使用呢
面试官：听说你精通Kafka，那我就考考你吧
面试官：不用慌尽管说，错了也没关系😊。。。
面试官：生产者重试机制导致Kafka重复消息，知道怎么处理吗
噢噢，Kafka支持幂等生产者，可以开启这个模块。
它是这样的，发送消息时同时发送生产者id、消息序列号，kafka会根据这些信息避免重复消息被写入。
面试官思考中…
面试官：Kafka事务，应该知道吧
嗯嗯知道的，消息队列事务主要应用在流式应用程序中。
比如主题A的消息A过来，消费者的消费逻辑是发送消息B给主题B。
所以我们要确保消费者成功提交偏移量、新消息，这两步操作要么成功要么都不成功。
剩余60%内容，订阅专栏后可继续查看/也可单篇购买
Java Offer训练营 文章被收录于专栏
👉以贴近现实的【面试官面试】形式帮助你系统学习后端技术 👉成体系知识帮你在后端进阶，每一道问答助你怒怼大厂面试官，收获大厂offer 👉《Java Offer训练营》包含Redis系列、MySQL系列、Kafka系列、ZooKeeper系列、JVM系列、多线程系列等等 👉制作不易，各位的支持是我创作的最大动力
投递小红书等公司9个岗位