循环Partition提交offset时为什么拆成了三段
来源:7-5 Consumer单Partition提交offset

小葱与奥特曼
2022-09-21
老师,我在试这段代码的时候,循环提交offset的时候为什么拆成了三段这样的提交?
使用的是自定义分区,i%2来计算的partition。
patition = 1 , offset = 379, key = key-1, value = value-1
patition = 1 , offset = 380, key = key-3, value = value-3
patition = 1 , offset = 381, key = key-5, value = value-5
patition = 1 , offset = 382, key = key-7, value = value-7
patition = 1 , offset = 383, key = key-9, value = value-9
patition = 1 , offset = 384, key = key-11, value = value-11
patition = 1 , offset = 385, key = key-13, value = value-13
patition = 1 , offset = 386, key = key-15, value = value-15
patition = 1 , offset = 387, key = key-17, value = value-17
patition = 1 , offset = 388, key = key-19, value = value-19
patition = 1 , offset = 389, key = key-21, value = value-21
patition = 1 , offset = 390, key = key-23, value = value-23
patition = 1 , offset = 391, key = key-25, value = value-25
patition = 1 , offset = 392, key = key-27, value = value-27
patition = 1 , offset = 393, key = key-29, value = value-29
patition = 1 , offset = 394, key = key-31, value = value-31
patition = 1 , offset = 395, key = key-33, value = value-33
patition = 1 , offset = 396, key = key-35, value = value-35
patition = 1 , offset = 397, key = key-37, value = value-37
patition = 1 , offset = 398, key = key-39, value = value-39
patition = 1 , offset = 399, key = key-41, value = value-41
patition = 1 , offset = 400, key = key-43, value = value-43
patition = 1 , offset = 401, key = key-45, value = value-45
patition = 1 , offset = 402, key = key-47, value = value-47
patition = 1 , offset = 403, key = key-49, value = value-49
patition = 1 , offset = 404, key = key-51, value = value-51
patition = 1 , offset = 405, key = key-53, value = value-53
patition = 1 , offset = 406, key = key-55, value = value-55
patition = 1 , offset = 407, key = key-57, value = value-57
patition = 1 , offset = 408, key = key-59, value = value-59
patition = 1 , offset = 409, key = key-61, value = value-61
patition = 1 , offset = 410, key = key-63, value = value-63
patition = 1 , offset = 411, key = key-65, value = value-65
patition = 1 , offset = 412, key = key-67, value = value-67
patition = 1 , offset = 413, key = key-69, value = value-69
patition = 1 , offset = 414, key = key-71, value = value-71
patition = 1 , offset = 415, key = key-73, value = value-73
patition = 1 , offset = 416, key = key-75, value = value-75
patition = 1 , offset = 417, key = key-77, value = value-77
=============partition - jiangzh-topic-1 end================
patition = 0 , offset = 377, key = key-0, value = value-0
patition = 0 , offset = 378, key = key-2, value = value-2
patition = 0 , offset = 379, key = key-4, value = value-4
patition = 0 , offset = 380, key = key-6, value = value-6
patition = 0 , offset = 381, key = key-8, value = value-8
patition = 0 , offset = 382, key = key-10, value = value-10
patition = 0 , offset = 383, key = key-12, value = value-12
patition = 0 , offset = 384, key = key-14, value = value-14
patition = 0 , offset = 385, key = key-16, value = value-16
patition = 0 , offset = 386, key = key-18, value = value-18
patition = 0 , offset = 387, key = key-20, value = value-20
patition = 0 , offset = 388, key = key-22, value = value-22
patition = 0 , offset = 389, key = key-24, value = value-24
patition = 0 , offset = 390, key = key-26, value = value-26
patition = 0 , offset = 391, key = key-28, value = value-28
patition = 0 , offset = 392, key = key-30, value = value-30
patition = 0 , offset = 393, key = key-32, value = value-32
patition = 0 , offset = 394, key = key-34, value = value-34
patition = 0 , offset = 395, key = key-36, value = value-36
patition = 0 , offset = 396, key = key-38, value = value-38
patition = 0 , offset = 397, key = key-40, value = value-40
patition = 0 , offset = 398, key = key-42, value = value-42
patition = 0 , offset = 399, key = key-44, value = value-44
patition = 0 , offset = 400, key = key-46, value = value-46
patition = 0 , offset = 401, key = key-48, value = value-48
patition = 0 , offset = 402, key = key-50, value = value-50
patition = 0 , offset = 403, key = key-52, value = value-52
patition = 0 , offset = 404, key = key-54, value = value-54
patition = 0 , offset = 405, key = key-56, value = value-56
patition = 0 , offset = 406, key = key-58, value = value-58
patition = 0 , offset = 407, key = key-60, value = value-60
patition = 0 , offset = 408, key = key-62, value = value-62
patition = 0 , offset = 409, key = key-64, value = value-64
patition = 0 , offset = 410, key = key-66, value = value-66
patition = 0 , offset = 411, key = key-68, value = value-68
patition = 0 , offset = 412, key = key-70, value = value-70
patition = 0 , offset = 413, key = key-72, value = value-72
patition = 0 , offset = 414, key = key-74, value = value-74
patition = 0 , offset = 415, key = key-76, value = value-76
patition = 0 , offset = 416, key = key-78, value = value-78
patition = 0 , offset = 417, key = key-80, value = value-80
patition = 0 , offset = 418, key = key-82, value = value-82
patition = 0 , offset = 419, key = key-84, value = value-84
patition = 0 , offset = 420, key = key-86, value = value-86
patition = 0 , offset = 421, key = key-88, value = value-88
patition = 0 , offset = 422, key = key-90, value = value-90
patition = 0 , offset = 423, key = key-92, value = value-92
patition = 0 , offset = 424, key = key-94, value = value-94
patition = 0 , offset = 425, key = key-96, value = value-96
patition = 0 , offset = 426, key = key-98, value = value-98
=============partition - jiangzh-topic-0 end================
patition = 1 , offset = 418, key = key-79, value = value-79
patition = 1 , offset = 419, key = key-81, value = value-81
patition = 1 , offset = 420, key = key-83, value = value-83
patition = 1 , offset = 421, key = key-85, value = value-85
patition = 1 , offset = 422, key = key-87, value = value-87
patition = 1 , offset = 423, key = key-89, value = value-89
patition = 1 , offset = 424, key = key-91, value = value-91
patition = 1 , offset = 425, key = key-93, value = value-93
patition = 1 , offset = 426, key = key-95, value = value-95
patition = 1 , offset = 427, key = key-97, value = value-97
patition = 1 , offset = 428, key = key-99, value = value-99
=============partition - jiangzh-topic-1 end================
写回答
1回答
-
慕粉0909169327
2022-11-16
第一步,按照partition遍历
第二步,取出当前paitition中的消费记录;
第三步,只对当前paitition的消费记录进行遍历
00
相似问题