2020-11-03 14:30:38,336 [bazaar.legion.us.all-clients.package-product-2-f8f7ca9e-840c-4bf8-ac6d-fea03b4581a2-StreamThread-2] INFO  o.a.k.s.p.i.StreamsPartitionAssignor - stream-thread [bazaar.legion.us.all-clients.package-product-2-f8f7ca9e-840c-4bf8-ac6d-fea03b4581a2-StreamThread-2-consumer] Assigned tasks to clients as
a3c0168a-1e5d-4e0d-8a31-4ec5f16b3a21=[activeTasks: ([0_3, 0_7, 0_11, 0_15, 1_3, 1_7, 1_11, 1_15, 2_3, 2_7, 2_11, 2_15]) standbyTasks: ([0_0, 0_4, 0_12, 1_0]) prevActiveTasks: ([0_3, 0_7, 0_11, 0_15, 1_3, 1_7, 1_11, 1_15, 2_3, 2_7, 2_11, 2_15]) prevStandbyTasks: ([]) prevOwnedPartitionsByConsumerId: ([bazaar.legion.us.all-clients.category-package-2-3, bazaar.legion.us.all-clients.category-package-2-7, bazaar.legion.us.all-clients.category-package-2-11, bazaar.legion.us.all-clients.category-package-2-15, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-0000000007-topic-3, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-0000000007-topic-7, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-0000000007-topic-11, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-0000000007-topic-15, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-0000000022-topic-3, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-0000000022-topic-7, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-0000000022-topic-11, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-0000000022-topic-15, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-RESPONSE-0000000015-topic-3, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-RESPONSE-0000000015-topic-7, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-RESPONSE-0000000015-topic-11, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-RESPONSE-0000000015-topic-15, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-RESPONSE-0000000030-topic-3, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-RESPONSE-0000000030-topic-7, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-RESPONSE-0000000030-topic-11, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-RESPONSE-0000000030-topic-15, bazaar.legion.us.megabus.brand-3, bazaar.legion.us.megabus.brand-7, bazaar.legion.us.megabus.brand-11, bazaar.legion.us.megabus.brand-15, bazaar.legion.us.megabus.product-3, bazaar.legion.us.megabus.product-7, bazaar.legion.us.megabus.product-11, bazaar.legion.us.megabus.product-15]) changelogOffsetTotalsByTask: ([0_3=1741237145, 0_7=1740223091, 0_11=1780660129, 0_15=1779114150, 1_3=-2, 1_7=116326637, 1_11=147825460, 1_15=102819849, 2_3=-2, 2_7=-2, 2_11=115009390, 2_15=134420963]) taskLagTotals: ([0_0=1721192151, 0_1=1738257098, 0_2=1744605250, 0_3=0, 0_4=1726783878, 0_5=1740958090, 0_6=1741596909, 0_7=0, 0_8=1718887062, 0_9=1780033871, 0_10=1773114183, 0_11=0, 0_12=1774103141, 0_13=1777203346, 0_14=1774433681, 0_15=4, 1_0=107919813, 1_1=198358417, 1_2=114798856, 1_3=-2, 1_4=106850928, 1_5=130647542, 1_6=108743697, 1_7=2, 1_8=113319884, 1_9=112113203, 1_10=101628434, 1_11=2, 1_12=104566778, 1_13=100195362, 1_14=117631992, 1_15=2, 2_0=126968031, 2_1=172027767, 2_2=162963162, 2_3=-2, 2_4=144664754, 2_5=122270849, 2_6=134386880, 2_7=-2, 2_8=141875014, 2_9=131254968, 2_10=115659235, 2_11=2, 2_12=135035732, 2_13=129730723, 2_14=145774733, 2_15=2]) capacity: 4 assigned: 16]
f8f7ca9e-840c-4bf8-ac6d-fea03b4581a2=[activeTasks: ([0_1, 0_5, 0_9, 0_13, 1_1, 1_5, 1_9, 1_13, 2_1, 2_5, 2_9, 2_13]) standbyTasks: ([]) prevActiveTasks: ([]) prevStandbyTasks: ([0_1, 0_5, 0_9, 0_13, 1_1, 1_5, 1_9, 1_13, 2_1, 2_5, 2_9, 2_13]) prevOwnedPartitionsByConsumerId: ([]) changelogOffsetTotalsByTask: ([0_1=1738257094, 0_5=1740958086, 0_9=1780033867, 0_13=1777203342, 1_1=198358415, 1_5=130647540, 1_9=112113201, 1_13=100195360, 2_1=172027765, 2_5=122270847, 2_9=131254966, 2_13=129730721]) taskLagTotals: ([0_0=1721192151, 0_1=4, 0_2=1744605250, 0_3=1741237145, 0_4=1726783878, 0_5=4, 0_6=1741596909, 0_7=1740223091, 0_8=1718887062, 0_9=4, 0_10=1773114183, 0_11=1780660129, 0_12=1774103141, 0_13=4, 0_14=1774433681, 0_15=1779114154, 1_0=107919813, 1_1=2, 1_2=114798856, 1_3=98041263, 1_4=106850928, 1_5=2, 1_6=108743697, 1_7=116326639, 1_8=113319884, 1_9=2, 1_10=101628434, 1_11=147825462, 1_12=104566778, 1_13=2, 1_14=117631992, 1_15=102819851, 2_0=126968031, 2_1=2, 2_2=162963162, 2_3=154888826, 2_4=144664754, 2_5=2, 2_6=134386880, 2_7=172111091, 2_8=141875014, 2_9=2, 2_10=115659235, 2_11=115009392, 2_12=135035732, 2_13=2, 2_14=145774733, 2_15=134420965]) capacity: 4 assigned: 12]
274f348d-7899-45f2-92b2-c2ea0eda2a43=[activeTasks: ([0_2, 0_6, 0_10, 0_14, 1_2, 1_6, 1_10, 1_14, 2_2, 2_6, 2_10, 2_14]) standbyTasks: ([]) prevActiveTasks: ([]) prevStandbyTasks: ([0_2, 0_6, 0_10, 0_14, 1_2, 1_6, 1_10, 1_14, 2_2, 2_6, 2_10, 2_14]) prevOwnedPartitionsByConsumerId: ([]) changelogOffsetTotalsByTask: ([0_2=1744605246, 0_6=1741596905, 0_10=1773114179, 0_14=1774433677, 1_2=114798854, 1_6=108743695, 1_10=101628432, 1_14=117631990, 2_2=162963160, 2_6=134386878, 2_10=115659233, 2_14=145774731]) taskLagTotals: ([0_0=1721192151, 0_1=1738257098, 0_2=4, 0_3=1741237145, 0_4=1726783878, 0_5=1740958090, 0_6=4, 0_7=1740223091, 0_8=1718887062, 0_9=1780033871, 0_10=4, 0_11=1780660129, 0_12=1774103141, 0_13=1777203346, 0_14=4, 0_15=1779114154, 1_0=107919813, 1_1=198358417, 1_2=2, 1_3=98041263, 1_4=106850928, 1_5=130647542, 1_6=2, 1_7=116326639, 1_8=113319884, 1_9=112113203, 1_10=2, 1_11=147825462, 1_12=104566778, 1_13=100195362, 1_14=2, 1_15=102819851, 2_0=126968031, 2_1=172027767, 2_2=2, 2_3=154888826, 2_4=144664754, 2_5=122270849, 2_6=2, 2_7=172111091, 2_8=141875014, 2_9=131254968, 2_10=2, 2_11=115009392, 2_12=135035732, 2_13=129730723, 2_14=2, 2_15=134420965]) capacity: 4 assigned: 12]
fe9b9ade-0cd9-464a-92a5-cdcf86b12851=[activeTasks: ([0_0, 0_4, 0_8, 0_12, 1_0, 1_4, 1_8, 1_12, 2_0, 2_4, 2_8, 2_12]) standbyTasks: ([0_2]) prevActiveTasks: ([]) prevStandbyTasks: ([0_0, 0_4, 0_8, 0_12, 1_0, 1_4, 1_8, 1_12, 2_0, 2_4, 2_8, 2_12]) prevOwnedPartitionsByConsumerId: ([]) changelogOffsetTotalsByTask: ([0_0=1721192147, 0_4=1726783874, 0_8=1718887058, 0_12=1774103137, 1_0=107919811, 1_4=106850926, 1_8=113319882, 1_12=104566776, 2_0=126968029, 2_4=144664752, 2_8=141875012, 2_12=135035730]) taskLagTotals: ([0_0=4, 0_1=1738257098, 0_2=1744605250, 0_3=1741237145, 0_4=4, 0_5=1740958090, 0_6=1741596909, 0_7=1740223091, 0_8=4, 0_9=1780033871, 0_10=1773114183, 0_11=1780660129, 0_12=4, 0_13=1777203346, 0_14=1774433681, 0_15=1779114154, 1_0=2, 1_1=198358417, 1_2=114798856, 1_3=98041263, 1_4=2, 1_5=130647542, 1_6=108743697, 1_7=116326639, 1_8=2, 1_9=112113203, 1_10=101628434, 1_11=147825462, 1_12=2, 1_13=100195362, 1_14=117631992, 1_15=102819851, 2_0=2, 2_1=172027767, 2_2=162963162, 2_3=154888826, 2_4=2, 2_5=122270849, 2_6=134386880, 2_7=172111091, 2_8=2, 2_9=131254968, 2_10=115659235, 2_11=115009392, 2_12=2, 2_13=129730723, 2_14=145774733, 2_15=134420965]) capacity: 4 assigned: 13].
2020-11-03 14:30:38,345 [bazaar.legion.us.all-clients.package-product-2-f8f7ca9e-840c-4bf8-ac6d-fea03b4581a2-StreamThread-2] INFO  o.a.k.s.p.i.StreamsPartitionAssignor - stream-thread [bazaar.legion.us.all-clients.package-product-2-f8f7ca9e-840c-4bf8-ac6d-fea03b4581a2-StreamThread-2-consumer] Removing task 0_15 from 1-1-6df5a938-f7ef-43b1-81af-f2bff0d16745 active assignment until it is safely revoked in followup rebalance
2020-11-03 14:30:38,345 [bazaar.legion.us.all-clients.package-product-2-f8f7ca9e-840c-4bf8-ac6d-fea03b4581a2-StreamThread-2] INFO  o.a.k.s.p.i.StreamsPartitionAssignor - stream-thread [bazaar.legion.us.all-clients.package-product-2-f8f7ca9e-840c-4bf8-ac6d-fea03b4581a2-StreamThread-2-consumer] Removing task 1_15 from 1-1-6df5a938-f7ef-43b1-81af-f2bff0d16745 active assignment until it is safely revoked in followup rebalance
2020-11-03 14:30:38,346 [bazaar.legion.us.all-clients.package-product-2-f8f7ca9e-840c-4bf8-ac6d-fea03b4581a2-StreamThread-2] INFO  o.a.k.s.p.i.StreamsPartitionAssignor - stream-thread [bazaar.legion.us.all-clients.package-product-2-f8f7ca9e-840c-4bf8-ac6d-fea03b4581a2-StreamThread-2-consumer] Adding removed stateful active task 0_15 as a standby for 1-1-6df5a938-f7ef-43b1-81af-f2bff0d16745 before it is safely revoked in followup rebalance
2020-11-03 14:30:38,346 [bazaar.legion.us.all-clients.package-product-2-f8f7ca9e-840c-4bf8-ac6d-fea03b4581a2-StreamThread-2] INFO  o.a.k.s.p.i.StreamsPartitionAssignor - stream-thread [bazaar.legion.us.all-clients.package-product-2-f8f7ca9e-840c-4bf8-ac6d-fea03b4581a2-StreamThread-2-consumer] Adding removed stateful active task 1_15 as a standby for 1-1-6df5a938-f7ef-43b1-81af-f2bff0d16745 before it is safely revoked in followup rebalance
2020-11-03 14:30:38,348 [bazaar.legion.us.all-clients.package-product-2-f8f7ca9e-840c-4bf8-ac6d-fea03b4581a2-StreamThread-2] INFO  o.a.k.s.p.i.StreamsPartitionAssignor - stream-thread [bazaar.legion.us.all-clients.package-product-2-f8f7ca9e-840c-4bf8-ac6d-fea03b4581a2-StreamThread-2-consumer] Requesting followup rebalance be scheduled immediately due to tasks changing ownership.
2020-11-03 14:30:38,350 [bazaar.legion.us.all-clients.package-product-2-f8f7ca9e-840c-4bf8-ac6d-fea03b4581a2-StreamThread-2] INFO  o.a.k.s.p.i.StreamsPartitionAssignor - stream-thread [bazaar.legion.us.all-clients.package-product-2-f8f7ca9e-840c-4bf8-ac6d-fea03b4581a2-StreamThread-2-consumer] Removing task 1_7 from 1-2-36748a72-6c63-4ea3-b4be-c1c273ecdce6 active assignment until it is safely revoked in followup rebalance
2020-11-03 14:30:38,351 [bazaar.legion.us.all-clients.package-product-2-f8f7ca9e-840c-4bf8-ac6d-fea03b4581a2-StreamThread-2] INFO  o.a.k.s.p.i.StreamsPartitionAssignor - stream-thread [bazaar.legion.us.all-clients.package-product-2-f8f7ca9e-840c-4bf8-ac6d-fea03b4581a2-StreamThread-2-consumer] Adding removed stateful active task 1_7 as a standby for 1-2-36748a72-6c63-4ea3-b4be-c1c273ecdce6 before it is safely revoked in followup rebalance
2020-11-03 14:30:38,351 [bazaar.legion.us.all-clients.package-product-2-f8f7ca9e-840c-4bf8-ac6d-fea03b4581a2-StreamThread-2] INFO  o.a.k.s.p.i.StreamsPartitionAssignor - stream-thread [bazaar.legion.us.all-clients.package-product-2-f8f7ca9e-840c-4bf8-ac6d-fea03b4581a2-StreamThread-2-consumer] Requesting followup rebalance be scheduled immediately due to tasks changing ownership.
2020-11-03 14:30:38,353 [bazaar.legion.us.all-clients.package-product-2-f8f7ca9e-840c-4bf8-ac6d-fea03b4581a2-StreamThread-2] INFO  o.a.k.s.p.i.StreamsPartitionAssignor - stream-thread [bazaar.legion.us.all-clients.package-product-2-f8f7ca9e-840c-4bf8-ac6d-fea03b4581a2-StreamThread-2-consumer] Removing task 1_11 from 1-4-09bd6dc3-a1a0-42a5-9897-bc3cf2800eca active assignment until it is safely revoked in followup rebalance
2020-11-03 14:30:38,353 [bazaar.legion.us.all-clients.package-product-2-f8f7ca9e-840c-4bf8-ac6d-fea03b4581a2-StreamThread-2] INFO  o.a.k.s.p.i.StreamsPartitionAssignor - stream-thread [bazaar.legion.us.all-clients.package-product-2-f8f7ca9e-840c-4bf8-ac6d-fea03b4581a2-StreamThread-2-consumer] Adding removed stateful active task 1_11 as a standby for 1-4-09bd6dc3-a1a0-42a5-9897-bc3cf2800eca before it is safely revoked in followup rebalance
2020-11-03 14:30:38,353 [bazaar.legion.us.all-clients.package-product-2-f8f7ca9e-840c-4bf8-ac6d-fea03b4581a2-StreamThread-2] INFO  o.a.k.s.p.i.StreamsPartitionAssignor - stream-thread [bazaar.legion.us.all-clients.package-product-2-f8f7ca9e-840c-4bf8-ac6d-fea03b4581a2-StreamThread-2-consumer] Requesting followup rebalance be scheduled immediately due to tasks changing ownership.
2020-11-03 14:30:38,354 [bazaar.legion.us.all-clients.package-product-2-f8f7ca9e-840c-4bf8-ac6d-fea03b4581a2-StreamThread-2] DEBUG o.a.k.s.p.i.StreamsPartitionAssignor - stream-thread [bazaar.legion.us.all-clients.package-product-2-f8f7ca9e-840c-4bf8-ac6d-fea03b4581a2-StreamThread-2-consumer] Requested client a3c0168a-1e5d-4e0d-8a31-4ec5f16b3a21 to schedule a followup rebalance
2020-11-03 14:30:38,355 [bazaar.legion.us.all-clients.package-product-2-f8f7ca9e-840c-4bf8-ac6d-fea03b4581a2-StreamThread-2] INFO  o.a.k.s.p.i.StreamsPartitionAssignor - stream-thread [bazaar.legion.us.all-clients.package-product-2-f8f7ca9e-840c-4bf8-ac6d-fea03b4581a2-StreamThread-2-consumer] Requesting followup rebalance be scheduled for 1604414438355 ms to probe for caught-up replica tasks.
2020-11-03 14:30:38,356 [bazaar.legion.us.all-clients.package-product-2-f8f7ca9e-840c-4bf8-ac6d-fea03b4581a2-StreamThread-2] DEBUG o.a.k.s.p.i.StreamsPartitionAssignor - stream-thread [bazaar.legion.us.all-clients.package-product-2-f8f7ca9e-840c-4bf8-ac6d-fea03b4581a2-StreamThread-2-consumer] Requested client f8f7ca9e-840c-4bf8-ac6d-fea03b4581a2 to schedule a followup rebalance
2020-11-03 14:30:38,365 [bazaar.legion.us.all-clients.package-product-2-f8f7ca9e-840c-4bf8-ac6d-fea03b4581a2-StreamThread-2] INFO  o.a.k.s.p.i.StreamsPartitionAssignor - stream-thread [bazaar.legion.us.all-clients.package-product-2-f8f7ca9e-840c-4bf8-ac6d-fea03b4581a2-StreamThread-2-consumer] Finished unstable assignment of tasks, a followup rebalance will be scheduled.