本文为博主九师兄(QQ:541711153 欢迎来探讨技术)原创文章,未经允许博主不允许转载。
- 1.概述
- 2. 案例
-
- 2.1 测试1
- 2.2 测试2
- 2.3 测试3
- M.扩展
1.概述
位移提交是使用消费者客户端过程中一个比较“讲究”的操作,位移提交的内容最终会保存到Kafka的内部主题_consumer offsets 中,对于主题_consumer_offsets 的深度掌握也可以让我们更好地理解和使用好位移提交。
一般情况下,当集群中第一次有消费者消费消息时会自动创建主题_consumer_offsets,不过它的副本因子还受offsets.topic.replication.factor参数的约束,这个参数的默认值为3 (下载安装的包中此值可能为1),分区数可以通过<



