大约 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不会实时更新，所以多次重启可能会重复消费
系统推荐
- Git笔记
- synchronized原理深度剖析
- MySQL常用命令
- HTTP1 0 vs HTTP1 1 vs WebSocket
- PostgreSQL定时备份
- Sublime Text 格式化JSON
- Centos离线安装Docker
- 推荐几个适用小工具
- PGSQL的json和 jsonb 读写性能测试
- 不重启 JVM，如何替换掉已经加载的类？
- Java语言完成notion笔记备份
- Lombok的Accessors导致EasyExcel读取失败
- 随机毒鸡汤：昨天一个小偷，来我家偷钱，我们一起找了一晚上。