42.preliminares.txt

% confluent-kafka==1.0.0
% kafka @ 121308c

['load', partitions, sum(partitions), errors]
['load', [81129, 81546, 81740, 81753, 81947, 81702, 82088, 81547], 653452, 5]
[consumer, assignment, consumed]
[0, [], 0]
[1, [], 0]
[2, [], 0]
[3, [], 0]
[4, [], 0]
[5, [], 0]
[6, [], 0]
[7, [], 0]
loaded 653452 unloaded 0

['load', [82412, 81406, 81086, 81834, 82013, 81385, 81506, 81804], 653446, 11]
[0, [], 164445]
[1, [], 165394]
[2, [], 164549]
[3, [], 164342]
[4, [], 164854]
[5, [], 165097]
[6, [], 165084]
[7, [], 165040]
loaded 653446 unloaded 1318805
['load', [81960, 81430, 81326, 81878, 81382, 81680, 81716, 82073], 653445, 12]
[0, [], 75235]
[1, [], 75397]
[2, [], 75893]
[3, [], 75161]
[4, [], 75551]
[5, [], 124830]
[6, [], 75812]
[7, [], 75566]
loaded 653445 unloaded 653445
['load', [81768, 81737, 81408, 81772, 81767, 82092, 81417, 81484], 653445, 12]
[0, [], 74661]
[1, [], 74603]
[2, [], 130219]
[3, [], 74747]
[4, [], 74443]
[5, [], 74834]
[6, [], 74831]
[7, [], 75107]
loaded 653445 unloaded 653445
['load', [81580, 81660, 82243, 81703, 81571, 81341, 81677, 81670], 653445, 12]
[0, [], 133533]
[1, [], 74401]
[2, [], 74150]
[3, [], 74004]
[4, [], 74700]
[5, [], 74262]
[6, [], 74197]
[7, [], 74198]
loaded 653445 unloaded 653445
['load', [81466, 81503, 81562, 81737, 81532, 81994, 81696, 81953], 653443, 14]
[0, [], 77510]
[1, [], 95137]
[2, [], 77465]
[3, [], 95290]
[4, [], 77193]
[5, [], 76886]
[6, [], 77068]
[7, [], 76894]
loaded 653443 unloaded 653443
['load', [81779, 81907, 81765, 81520, 81874, 81535, 81422, 81643], 653445, 12]
[0, [], 81779]
[1, [], 81422]
[2, [], 81874]
[3, [], 81765]
[4, [], 81535]
[5, [], 81643]
[6, [], 81520]
[7, [], 81907]
loaded 653445 unloaded 653445
['load', [82072, 81323, 81289, 81610, 81527, 81573, 82230, 81821], 653445, 12]
[0, [], 99418]
[1, [], 98941]
[2, [], 75563]
[3, [], 75638]
[4, [], 75937]
[5, [], 75928]
[6, [], 75776]
[7, [], 76244]
loaded 653445 unloaded 653445
2min 59s ± 6.79 s per loop (mean ± std. dev. of 7 runs, 1 loop each)