Kafka
大约 2 分钟
- kafka的副本是针对分区的。也就是说不同分区的leader可能是不一样的。
新消费组
设置:AUTO_OFFSET_RESET_CONFIG earliest
第一次启动,从最开始的offset开始消费。然后不改动任何代码和配置重启,还是从最开始的offset开始消费,多次启动,仍然是从最开始的offset开始消费。
也就是说,新的消费组如果设置了earliest,kafka是不会记录消费位置的
设置:AUTO_OFFSET_RESET_CONFIG none
启动则报错
设置:AUTO_OFFSET_RESET_CONFIG earliest
第一次启动,从最新的offset开始消费。同时offset会实时更新。然后关闭,此时的offset为B。然后不改动任何代码和配置多次重启后,消费的offset不会实时更新,所以多次重启可能会重复消费
不配置AUTO_OFFSET_RESET_CONFIG
第一次启动,从最新的offset开始消费。同时offset会实时更新。然后关闭,此时的offset为B。然后不改动任何代码和配置多次重启后,消费的offset不会实时更新,所以多次重启可能会重复消费
系统推荐
- synchronized原理深度剖析
- MySQL常用命令
- 来个JVM冷知识
- Spring Cloud Gateway收到的是http请求,但schema却是https
- 手把手教你制作Cookie、Local、Session数据导出插件
- JetBrains IDE 全破解
- 提取Docker镜像中的文件
- Spring RetryTemplate
- InnoDB存储引擎
- SpringBoot服务在服务启动完成前被提前注册到nacos
- SpringCloud总体认识
- GitHub Workflow突然报错
- 随机毒鸡汤:觉得无聊?把书拿出来,你就知道自己想玩什么了。