2020-11-02 06:35:13,405 [bazaar.legion.us.all-clients.package-product-2-ad6a91c3-6754-4898-8eaa-a3b8a65af3d2-StreamThread-2] INFO  o.a.k.s.p.i.StreamsPartitionAssignor - stream-thread [bazaar.legion.us.all-clients.package-product-2-ad6a91c3-6754-4898-8eaa-a3b8a65af3d2-StreamThread-2-consumer] Assigned tasks to clients as 
6977689b-ef90-482a-8abe-9399745e0e5f=[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: ([]) 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=-2, 0_7=-2, 0_11=-2, 0_15=-2, 1_3=-2, 1_7=-2, 1_11=-2, 1_15=-2, 2_3=-2, 2_7=-2, 2_11=-2, 2_15=-2]) taskLagTotals: ([0_0=1703631388, 0_1=1720707474, 0_2=1727019115, 0_3=-2, 0_4=1709223291, 0_5=1723385442, 0_6=1724025587, 0_7=-2, 0_8=1701315613, 0_9=1762447220, 0_10=1755565901, 0_11=-2, 0_12=1756526580, 0_13=1759633237, 0_14=1756849907, 0_15=-2, 1_0=105828593, 1_1=196749953, 1_2=111845107, 1_3=-2, 1_4=104886542, 1_5=127596597, 1_6=106744749, 1_7=-2, 1_8=111467917, 1_9=110108280, 1_10=99607614, 1_11=-2, 1_12=102209588, 1_13=98339759, 1_14=115661533, 1_15=-2, 2_0=124842957, 2_1=167701404, 2_2=159458557, 2_3=-2, 2_4=140427032, 2_5=118889328, 2_6=131164472, 2_7=-2, 2_8=138898356, 2_9=128273006, 2_10=113277804, 2_11=-2, 2_12=132262113, 2_13=127572900, 2_14=142904304, 2_15=-2]) capacity: 4 assigned: 12]
86bfeec6-521e-405e-b6a3-7cfc297a306e=[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: ([]) prevActiveTasks: ([0_0, 0_4, 0_8, 0_12, 1_0, 1_4, 1_8, 1_12, 2_0, 2_4, 2_8, 2_12]) prevStandbyTasks: ([]) prevOwnedPartitionsByConsumerId: ([bazaar.legion.us.all-clients.category-package-2-0, bazaar.legion.us.all-clients.category-package-2-4, bazaar.legion.us.all-clients.category-package-2-8, bazaar.legion.us.all-clients.category-package-2-12, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-0000000007-topic-0, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-0000000007-topic-4, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-0000000007-topic-8, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-0000000007-topic-12, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-0000000022-topic-0, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-0000000022-topic-4, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-0000000022-topic-8, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-0000000022-topic-12, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-RESPONSE-0000000015-topic-0, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-RESPONSE-0000000015-topic-4, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-RESPONSE-0000000015-topic-8, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-RESPONSE-0000000015-topic-12, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-RESPONSE-0000000030-topic-0, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-RESPONSE-0000000030-topic-4, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-RESPONSE-0000000030-topic-8, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-RESPONSE-0000000030-topic-12, bazaar.legion.us.megabus.brand-0, bazaar.legion.us.megabus.brand-4, bazaar.legion.us.megabus.brand-8, bazaar.legion.us.megabus.brand-12, bazaar.legion.us.megabus.product-0, bazaar.legion.us.megabus.product-4, bazaar.legion.us.megabus.product-8, bazaar.legion.us.megabus.product-12]) changelogOffsetTotalsByTask: ([0_0=-2, 0_4=-2, 0_8=-2, 0_12=-2, 1_0=-2, 1_4=-2, 1_8=-2, 1_12=-2, 2_0=-2, 2_4=-2, 2_8=-2, 2_12=-2]) taskLagTotals: ([0_0=-2, 0_1=1720707474, 0_2=1727019115, 0_3=1723661645, 0_4=-2, 0_5=1723385442, 0_6=1724025587, 0_7=1722623263, 0_8=-2, 0_9=1762447220, 0_10=1755565901, 0_11=1763091189, 0_12=-2, 0_13=1759633237, 0_14=1756849907, 0_15=1761561276, 1_0=-2, 1_1=196749953, 1_2=111845107, 1_3=96208848, 1_4=-2, 1_5=127596597, 1_6=106744749, 1_7=114273847, 1_8=-2, 1_9=110108280, 1_10=99607614, 1_11=145398138, 1_12=-2, 1_13=98339759, 1_14=115661533, 1_15=100868701, 2_0=-2, 2_1=167701404, 2_2=159458557, 2_3=151188954, 2_4=-2, 2_5=118889328, 2_6=131164472, 2_7=169041586, 2_8=-2, 2_9=128273006, 2_10=113277804, 2_11=112702230, 2_12=-2, 2_13=127572900, 2_14=142904304, 2_15=131307886]) capacity: 4 assigned: 12]
d3207b83-e959-455b-9d63-95f487198377=[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: ([0_2, 0_6, 0_10, 0_14, 1_2, 1_6, 1_10, 1_14, 2_2, 2_6, 2_10]) prevStandbyTasks: ([0_13, 2_14]) prevOwnedPartitionsByConsumerId: ([bazaar.legion.us.all-clients.category-package-2-2, bazaar.legion.us.all-clients.category-package-2-6, bazaar.legion.us.all-clients.category-package-2-10, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-0000000007-topic-2, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-0000000007-topic-6, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-0000000007-topic-10, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-0000000007-topic-14, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-0000000022-topic-2, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-0000000022-topic-6, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-0000000022-topic-10, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-RESPONSE-0000000015-topic-2, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-RESPONSE-0000000015-topic-6, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-RESPONSE-0000000015-topic-10, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-RESPONSE-0000000015-topic-14, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-RESPONSE-0000000030-topic-2, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-RESPONSE-0000000030-topic-6, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-RESPONSE-0000000030-topic-10, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-RESPONSE-0000000030-topic-14, bazaar.legion.us.megabus.brand-2, bazaar.legion.us.megabus.brand-6, bazaar.legion.us.megabus.brand-10, bazaar.legion.us.megabus.brand-14, bazaar.legion.us.megabus.product-2, bazaar.legion.us.megabus.product-6, bazaar.legion.us.megabus.product-10, bazaar.legion.us.megabus.product-14]) changelogOffsetTotalsByTask: ([0_2=-2, 0_6=-2, 0_10=-2, 0_13=1759633233, 0_14=-2, 1_2=-2, 1_6=-2, 1_10=-2, 1_14=-2, 2_2=-2, 2_6=-2, 2_10=-2, 2_14=142904302]) taskLagTotals: ([0_0=1703631388, 0_1=1720707474, 0_2=-2, 0_3=1723661645, 0_4=1709223291, 0_5=1723385442, 0_6=-2, 0_7=1722623263, 0_8=1701315613, 0_9=1762447220, 0_10=-2, 0_11=1763091189, 0_12=1756526580, 0_13=4, 0_14=-2, 0_15=1761561276, 1_0=105828593, 1_1=196749953, 1_2=-2, 1_3=96208848, 1_4=104886542, 1_5=127596597, 1_6=-2, 1_7=114273847, 1_8=111467917, 1_9=110108280, 1_10=-2, 1_11=145398138, 1_12=102209588, 1_13=98339759, 1_14=-2, 1_15=100868701, 2_0=124842957, 2_1=167701404, 2_2=-2, 2_3=151188954, 2_4=140427032, 2_5=118889328, 2_6=-2, 2_7=169041586, 2_8=138898356, 2_9=128273006, 2_10=-2, 2_11=112702230, 2_12=132262113, 2_13=127572900, 2_14=2, 2_15=131307886]) capacity: 4 assigned: 12]
ad6a91c3-6754-4898-8eaa-a3b8a65af3d2=[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: ([0_1, 0_5, 0_9, 1_1, 1_5, 1_9, 1_13, 2_1, 2_5, 2_9, 2_13]) prevStandbyTasks: ([0_13]) prevOwnedPartitionsByConsumerId: ([bazaar.legion.us.all-clients.category-package-2-1, bazaar.legion.us.all-clients.category-package-2-5, bazaar.legion.us.all-clients.category-package-2-9, bazaar.legion.us.all-clients.category-package-2-13, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-0000000007-topic-1, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-0000000007-topic-5, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-0000000007-topic-9, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-0000000007-topic-13, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-0000000022-topic-1, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-0000000022-topic-5, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-0000000022-topic-9, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-0000000022-topic-13, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-RESPONSE-0000000015-topic-1, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-RESPONSE-0000000015-topic-5, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-RESPONSE-0000000015-topic-9, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-RESPONSE-0000000030-topic-1, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-RESPONSE-0000000030-topic-5, bazaar.legion.us.all-clients.package-product-2-KTABLE-FK-JOIN-SUBSCRIPTION-RESPONSE-0000000030-topic-9, bazaar.legion.us.megabus.brand-1, bazaar.legion.us.megabus.brand-5, bazaar.legion.us.megabus.brand-9, bazaar.legion.us.megabus.brand-13, bazaar.legion.us.megabus.product-1, bazaar.legion.us.megabus.product-5, bazaar.legion.us.megabus.product-9]) changelogOffsetTotalsByTask: ([0_1=-2, 0_5=-2, 0_9=-2, 0_13=1759632331, 1_1=-2, 1_5=-2, 1_9=-2, 1_13=-2, 2_1=-2, 2_5=-2, 2_9=-2, 2_13=-2]) taskLagTotals: ([0_0=1703631388, 0_1=-2, 0_2=1727019115, 0_3=1723661645, 0_4=1709223291, 0_5=-2, 0_6=1724025587, 0_7=1722623263, 0_8=1701315613, 0_9=-2, 0_10=1755565901, 0_11=1763091189, 0_12=1756526580, 0_13=906, 0_14=1756849907, 0_15=1761561276, 1_0=105828593, 1_1=-2, 1_2=111845107, 1_3=96208848, 1_4=104886542, 1_5=-2, 1_6=106744749, 1_7=114273847, 1_8=111467917, 1_9=-2, 1_10=99607614, 1_11=145398138, 1_12=102209588, 1_13=-2, 1_14=115661533, 1_15=100868701, 2_0=124842957, 2_1=-2, 2_2=159458557, 2_3=151188954, 2_4=140427032, 2_5=-2, 2_6=131164472, 2_7=169041586, 2_8=138898356, 2_9=-2, 2_10=113277804, 2_11=112702230, 2_12=132262113, 2_13=-2, 2_14=142904304, 2_15=131307886]) capacity: 4 assigned: 12].
2020-11-02 06:35:13,407 [bazaar.legion.us.all-clients.package-product-2-ad6a91c3-6754-4898-8eaa-a3b8a65af3d2-StreamThread-2] INFO  o.a.k.s.p.i.StreamsPartitionAssignor - stream-thread [bazaar.legion.us.all-clients.package-product-2-ad6a91c3-6754-4898-8eaa-a3b8a65af3d2-StreamThread-2-consumer] Finished stable assignment of tasks, no followup rebalances required.