当前位置: 首页 > wzjs >正文

渭南经开区seo综合查询怎么用的

渭南经开区,seo综合查询怎么用的,南京外贸推广,深圳企业社保网站官网不讲道理,先抛问题 日志发现Kafka同一个消费者在一段时间内对同一条消息多次消费。 原理不讲,先上配置 # 是否自动提交offset spring.kafka.consumer.enable-auto-committrue # 提交offset延时(接收到消息后多久提交offset) spring.kafka.consumer…

不讲道理,先抛问题

日志发现Kafka同一个消费者在一段时间内对同一条消息多次消费。
请添加图片描述
在这里插入图片描述
在这里插入图片描述

原理不讲,先上配置

# 是否自动提交offset
spring.kafka.consumer.enable-auto-commit=true
# 提交offset延时(接收到消息后多久提交offset)
spring.kafka.consumer.auto.commit.interval.ms=1000
# latest:重置为分区中最新的offset(消费分区中新产生的数据);
spring.kafka.consumer.auto-offset-reset=latest
# Rebalance 超时
spring.kafka.consumer.properties.max.poll.interval.ms=300000  # 5 分钟 

三言两语,背景简介

Kafka一个生产者,一个消费者,消费同一个Topic,但是其中的某些消息处理耗时超过5分钟。

捕获问题,深度剖析

Kafka自动提交offset后因默认max.poll.interval.ms设置5分钟没有调用poll()从而发生Reblance重复消费的问题。

解决方案,横向对比

  1. offset自动提交改为手动提交
    spring.kafka.consumer.enable-auto-commit=false
@KafkaListener(topics = "generateYyVoucher-topic", groupId = "defaultConsumerGroup")
public void generateYyVoucher(ConsumerRecord<String, String> record, Acknowledgment ack) {try {...// 提交 Offsetack.acknowledge();} catch (Exception e) {log.error("Message processing failed: ", e);// 如果处理失败,Offset 不会被提交}
}

2.增加max.poll.interval.ms延迟
spring.kafka.consumer.properties.max.poll.interval.ms=900000 # 设置为15分钟

总结:但是上述两种方案均不能从根本上解决消费者重复消费的问题!根本问题是在于Reblance消费重组原因导致!
第1种只能解决offset偏移量不会重发消费当前消息,但可能会消费上一个消息;
第2种增加延迟,当业务逻辑超过设置时间时仍然会重复消费。

重复消费,最佳解决方案

幂等消费标识(唯一标识)

        // 幂等消费标识(唯一标识),以解决Kafka自动提交offset后因默认max.poll.interval.ms设置5分钟没有调用poll()从而发生Reblance重复消费的问题String redisKey = "voucher:processing:" + ledgerId;// 检查 Redis 中是否已存在该幂等标识if (stringRedisTemplate.hasKey(redisKey)) {return;}// 设置 Redis 中的标识为正在处理中(可以设置一个有效期,比如 30 分钟)stringRedisTemplate.opsForValue().set(redisKey, "processing", 30, TimeUnit.MINUTES);

氪肝提示,不是温馨

面试八股文准备再多的中间件问题,也不如真正项目上实际遇到的问题。中间件也不是每个都要用,只关注项目上使用的就行。只有真正经历解决过一两个实际问题,才能了解中间件。

http://www.dtcms.com/wzjs/102037.html

相关文章:

  • 做众筹的网站有几个合肥百度搜索排名优化
  • 阿里巴巴企业网站怎么做seo需要付费吗
  • 谷歌网站提交入口百度助手app下载
  • 泰州网站建设哪家好友情链接交易
  • 企业网站开发实训目的杭州seo整站优化
  • 做网站是学什么编程语言深圳seo
  • 如何自做自己的网站西安关键词排名软件
  • 丰宁坝上草原网站建设百度站长平台有哪些功能
  • 成都比较好的网站设计公司广告接单平台app
  • 如何制作动漫网站模板山西seo优化
  • 定制家具品牌杭州seo按天计费
  • 做网站用c语言吗百度模拟点击
  • 网站建设新技术google seo 优化
  • 源码网站代理优化大师 win10下载
  • 网站文件名格式热门搜索排行榜
  • 湛江今日头条seo顾问收费
  • 自己做的网站怎么样把里面的内容下载下来宁波seo教程网
  • 县区网站集约化建设性能优化工具
  • 网站建设实训的方法定西seo排名
  • 淄博网站建设报价关于搜索引擎的搜索技巧
  • 网站推广风险seo招聘网
  • 企业网站开发用什么好网站设计制作教程
  • 网站开发实训内容seo关键词排名优化教程
  • 彩票网站开发系统软件开发外包公司
  • 个性化推荐网站开发源码网络服务合同纠纷
  • 网站上面的在线咨询是怎么做的全网最全搜索引擎app
  • 小程序商城如何运营seo的英文全称是什么
  • 网站建设注意内容营销
  • 上海建网站公司排名网络推广公司联系方式
  • 网站做排名有用吗seo关键词优化公司