首页 > 其他分享 >使用kafka时踩过的坑

使用kafka时踩过的坑

时间:2022-12-02 16:01:20浏览次数:39  
标签:partition 订单号 kafka 失败 下单 使用 解决

1,如何保证消费顺序,比如同一个用户的下单,撤单肯定有先后顺序。

解决方法:把订单号放在topic中指定partition。

2,用户因为网络延迟导致下单失败,后端看不到用户订单消息,但是却撤单了。

解决方法:消费者消费消息的时候,先判断订单号是否属于下单失败,如果是,则把下单失败的消息放到重试表中,使用重试任务7次还失败,则下单失败。

3,消息积压

解决方法:1,精简发送的报文,减少网络传输,2,检查partition是否有积压,尽量保持每个partition均衡,3,检查数据库性能是否满足要求,可能有大表。

 4,重复消费

解决方法:接口幂等

标签:partition,订单号,kafka,失败,下单,使用,解决
From: https://www.cnblogs.com/nizuimeiabc1/p/16944720.html

相关文章

  • .net6&7中如何优雅且高性能的使用Json序列化
    .net中的SourceGenerator让开发者编可以写分析器,在项目代码编译时,分析器分析项目既有的静态代码,允许添加源代码到GeneratorExecutionContext中,一同与既有的代码参与编译。......
  • react18中useCallback与memo使用
     1、父组件Demo3Count组件缓存有两种方法a、  b、    2、子组件    3、效果3.1、初始均渲染  3.2、点击b......
  • 基于现有Kubernetes集群使用Rook部署Ceph集群
    基于现有Kubernetes集群使用Rook部署Ceph集群一、前言本片文章主要是基于现有的k8s集群环境使用Rook部署Ceph集群Rook官方文档:https://rook.github.io/docs......
  • Spring-RetryTemplate-RestTemplate的使用
    ------------------------------------------------------------------------------------1.基本概念1.1应用场景1.1.1数据同步有时候项目需要进行同步数据(定时任......
  • Springboot 整合 SpringCache 使用 Redis 作为缓存
    一直以来对缓存都是一知半解,从没有正经的接触并使用一次,今天腾出时间研究一下缓存技术,开发环境为OpenJDK17与SpringBoot2.7.5源代码下载地址:https://hanzhe.lanzoue.com/i......
  • JAVA面试题--Kafka
    Kafka1.为什么要使用kafka?为什么要使用消息队列?2.Kafka中的ISR、AR又代表什么?ISR的伸缩又指什么?3.kafka中的broker是干什么的?4.kafka中的zookeeper起到什么作用?可......
  • 使用post接口进行大批量导出文件
    在工作中,使用get方法导出文件会遇到一些问题:url长度限制,传入id量大且加载速度慢,所以抛弃以前的请求下载方式,使用post接口进行请求下载!  本次的导出文件为excel文件,其他......
  • spring boot使用阿里云分片上传讲解示例
    阿里云分片上传importcom.aliyun.oss.ClientException;importcom.aliyun.oss.OSS;importcom.aliyun.oss.OSSClientBuilder;importcom.aliyun.oss.OSSException;im......
  • Kafka概念
    发布-订阅模型:kafka消息模型发布-订阅模型主要是为了解决队列模型存在的问题。发布订阅模型(Pub-sub)使用主题(topic)作为消息通信载体,类似于广播模式;发布者发布一条消息,该消息......
  • 使用DocXToPdfConverter把Docx转成Pdf文件
    1、安装DocXToPdfConverterInstall-PackageDocXToPdfConverter2、下载LibreOfficehttps://www.libreoffice.org/download/portable-versions/下载后安装软件。3、......