[2017-05-24 15:26:10,567] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Creating consumer client (org.apache.kafka.streams.processor.internals.StreamThread:465) [2017-05-24 15:26:10,656] WARN Error while loading kafka-version.properties :null (org.apache.kafka.common.utils.AppInfoParser:42) [2017-05-24 15:26:10,658] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Creating restore consumer client (org.apache.kafka.streams.processor.internals.StreamThread:475) [2017-05-24 15:26:10,671] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] State transition from NOT_RUNNING to RUNNING. (org.apache.kafka.streams.processor.internals.StreamThread:972) [2017-05-24 15:26:10,951] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Starting (org.apache.kafka.streams.processor.internals.StreamThread:515) [2017-05-24 15:26:10,972] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] at state RUNNING: partitions [] revoked at the beginning of consumer rebalance. current assigned active tasks: [] current assigned standby tasks: [] (org.apache.kafka.streams.processor.internals.StreamThread:199) [2017-05-24 15:26:10,972] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] State transition from RUNNING to PARTITIONS_REVOKED. (org.apache.kafka.streams.processor.internals.StreamThread:972) [2017-05-24 15:26:10,972] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] suspendTasksAndState: suspending all active tasks [] and standby tasks [] (org.apache.kafka.streams.processor.internals.StreamThread:1097) [2017-05-24 15:26:10,973] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Updating suspended tasks to contain active tasks [] (org.apache.kafka.streams.processor.internals.StreamThread:1391) [2017-05-24 15:26:10,973] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Removing all active tasks [] (org.apache.kafka.streams.processor.internals.StreamThread:1398) [2017-05-24 15:26:10,973] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Removing all standby tasks [] (org.apache.kafka.streams.processor.internals.StreamThread:1412) [2017-05-24 15:26:10,973] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] partition revocation took 1 ms. suspended active tasks: [] suspended standby tasks: [] previous active tasks: [] (org.apache.kafka.streams.processor.internals.StreamThread:221) [2017-05-24 15:26:10,975] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] found [us.Trigger] topics possibly matching regex (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:258) [2017-05-24 15:26:10,976] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] updating builder with SubscriptionUpdates{updatedTopicSubscriptions=[us.Trigger]} topic(s) with possible matching regex subscription(s) (org.apache.kafka.streams.processor.TopologyBuilder:1550) [2017-05-24 15:26:10,976] DEBUG nodeToSourceTopics {KSTREAM-SOURCE-0000000000=[us.Trigger]} (org.apache.kafka.streams.processor.TopologyBuilder:1371) [2017-05-24 15:26:13,988] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Constructed client metadata {8882e71b-7b0f-4341-8447-8b056415bcb9=ClientMetadata{hostInfo=null, consumers=[reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1-consumer-07122eac-9a4e-4cd0-8821-d9a901c4608c], state=[activeTasks: ([]) standbyTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1]}} from the member subscriptions. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:310) [2017-05-24 15:26:13,991] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Starting to validate internal topics in partition assignor. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:617) [2017-05-24 15:26:13,991] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Completed validating internal topics in partition assignor (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:651) [2017-05-24 15:26:13,991] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Created repartition topics [] from the parsed topology. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:396) [2017-05-24 15:26:13,992] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Starting to validate internal topics in partition assignor. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:617) [2017-05-24 15:26:13,992] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Completed validating internal topics in partition assignor (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:651) [2017-05-24 15:26:13,992] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Created state changelog topics {} from the parsed topology. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:471) [2017-05-24 15:26:13,992] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Assigning tasks [0_0, 0_1, 0_2] to clients {8882e71b-7b0f-4341-8447-8b056415bcb9=[activeTasks: ([]) standbyTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1]} with number of replicas 0 (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:481) [2017-05-24 15:26:13,995] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Assigned tasks to clients as {8882e71b-7b0f-4341-8447-8b056415bcb9=[activeTasks: ([0_0, 0_1, 0_2]) standbyTasks: ([]) assignedTasks: ([0_0, 0_1, 0_2]) prevActiveTasks: ([]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1]}. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:487) [2017-05-24 15:26:14,003] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] at state PARTITIONS_REVOKED: new partitions [us.Trigger-2, us.Trigger-1, us.Trigger-0] assigned at the end of consumer rebalance. assigned active tasks: [0_0, 0_1, 0_2] assigned standby tasks: [] current suspended active tasks: [] current suspended standby tasks: [] previous active tasks: [] (org.apache.kafka.streams.processor.internals.StreamThread:154) [2017-05-24 15:26:14,005] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] State transition from PARTITIONS_REVOKED to ASSIGNING_PARTITIONS. (org.apache.kafka.streams.processor.internals.StreamThread:972) [2017-05-24 15:26:14,005] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Adding assigned tasks as active {0_0=[us.Trigger-0], 0_1=[us.Trigger-1], 0_2=[us.Trigger-2]} (org.apache.kafka.streams.processor.internals.StreamThread:1271) [2017-05-24 15:26:14,005] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] New active tasks to be created: {0_0=[us.Trigger-0], 0_1=[us.Trigger-1], 0_2=[us.Trigger-2]} (org.apache.kafka.streams.processor.internals.StreamThread:1302) [2017-05-24 15:26:14,005] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Creating active task 0_0 with assigned partitions [[us.Trigger-0]] (org.apache.kafka.streams.processor.internals.StreamThread:1221) [2017-05-24 15:26:14,020] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Creating shared producer client (org.apache.kafka.streams.processor.internals.StreamThread:1254) [2017-05-24 15:26:14,049] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Acquired state dir lock for task 0_0 (org.apache.kafka.streams.processor.internals.StateDirectory:135) [2017-05-24 15:26:14,050] INFO task [0_0] Created state store manager for task 0_0 with the acquired state dir lock (org.apache.kafka.streams.processor.internals.ProcessorStateManager:122) [2017-05-24 15:26:14,064] DEBUG task [0_0] Initializing (org.apache.kafka.streams.processor.internals.StreamTask:138) [2017-05-24 15:26:14,064] DEBUG task [0_0] Initializing state stores (org.apache.kafka.streams.processor.internals.AbstractTask:194) [2017-05-24 15:26:14,064] DEBUG task [0_0] Updating store offset limits {} (org.apache.kafka.streams.processor.internals.AbstractTask:171) [2017-05-24 15:26:14,068] INFO task [0_0] Register global stores [] (org.apache.kafka.streams.processor.internals.ProcessorStateManager:352) [2017-05-24 15:26:14,068] DEBUG task [0_0] Initializing processor nodes of the topology (org.apache.kafka.streams.processor.internals.StreamTask:316) [2017-05-24 15:26:14,075] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Created active task 0_0 with assigned partitions [us.Trigger-0] (org.apache.kafka.streams.processor.internals.StreamThread:1240) [2017-05-24 15:26:14,075] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Creating active task 0_1 with assigned partitions [[us.Trigger-1]] (org.apache.kafka.streams.processor.internals.StreamThread:1221) [2017-05-24 15:26:14,075] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Acquired state dir lock for task 0_1 (org.apache.kafka.streams.processor.internals.StateDirectory:135) [2017-05-24 15:26:14,076] INFO task [0_1] Created state store manager for task 0_1 with the acquired state dir lock (org.apache.kafka.streams.processor.internals.ProcessorStateManager:122) [2017-05-24 15:26:14,076] DEBUG task [0_1] Initializing (org.apache.kafka.streams.processor.internals.StreamTask:138) [2017-05-24 15:26:14,077] DEBUG task [0_1] Initializing state stores (org.apache.kafka.streams.processor.internals.AbstractTask:194) [2017-05-24 15:26:14,077] DEBUG task [0_1] Updating store offset limits {} (org.apache.kafka.streams.processor.internals.AbstractTask:171) [2017-05-24 15:26:14,077] INFO task [0_1] Register global stores [] (org.apache.kafka.streams.processor.internals.ProcessorStateManager:352) [2017-05-24 15:26:14,077] DEBUG task [0_1] Initializing processor nodes of the topology (org.apache.kafka.streams.processor.internals.StreamTask:316) [2017-05-24 15:26:14,079] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Created active task 0_1 with assigned partitions [us.Trigger-1] (org.apache.kafka.streams.processor.internals.StreamThread:1240) [2017-05-24 15:26:14,079] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Creating active task 0_2 with assigned partitions [[us.Trigger-2]] (org.apache.kafka.streams.processor.internals.StreamThread:1221) [2017-05-24 15:26:14,080] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Acquired state dir lock for task 0_2 (org.apache.kafka.streams.processor.internals.StateDirectory:135) [2017-05-24 15:26:14,080] INFO task [0_2] Created state store manager for task 0_2 with the acquired state dir lock (org.apache.kafka.streams.processor.internals.ProcessorStateManager:122) [2017-05-24 15:26:14,081] DEBUG task [0_2] Initializing (org.apache.kafka.streams.processor.internals.StreamTask:138) [2017-05-24 15:26:14,081] DEBUG task [0_2] Initializing state stores (org.apache.kafka.streams.processor.internals.AbstractTask:194) [2017-05-24 15:26:14,081] DEBUG task [0_2] Updating store offset limits {} (org.apache.kafka.streams.processor.internals.AbstractTask:171) [2017-05-24 15:26:14,081] INFO task [0_2] Register global stores [] (org.apache.kafka.streams.processor.internals.ProcessorStateManager:352) [2017-05-24 15:26:14,081] DEBUG task [0_2] Initializing processor nodes of the topology (org.apache.kafka.streams.processor.internals.StreamTask:316) [2017-05-24 15:26:14,084] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Created active task 0_2 with assigned partitions [us.Trigger-2] (org.apache.kafka.streams.processor.internals.StreamThread:1240) [2017-05-24 15:26:14,085] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Starting restoring state stores from changelog topics [] (org.apache.kafka.streams.processor.internals.StoreChangelogReader:121) [2017-05-24 15:26:14,085] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Took 1 ms to restore all active states (org.apache.kafka.streams.processor.internals.StoreChangelogReader:156) [2017-05-24 15:26:14,085] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Adding assigned standby tasks {0_0=[us.Trigger-0], 0_1=[us.Trigger-1], 0_2=[us.Trigger-2]} (org.apache.kafka.streams.processor.internals.StreamThread:1336) [2017-05-24 15:26:14,085] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] New standby tasks to be created: {} (org.apache.kafka.streams.processor.internals.StreamThread:1355) [2017-05-24 15:26:14,086] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] State transition from ASSIGNING_PARTITIONS to RUNNING. (org.apache.kafka.streams.processor.internals.StreamThread:972) [2017-05-24 15:26:14,086] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] partition assignment took 83 ms. current active tasks: [0_0, 0_1, 0_2] current standby tasks: [] (org.apache.kafka.streams.processor.internals.StreamThread:187) [2017-05-24 15:26:17,018] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] at state RUNNING: partitions [us.Trigger-2, us.Trigger-1, us.Trigger-0] revoked at the beginning of consumer rebalance. current assigned active tasks: [0_0, 0_1, 0_2] current assigned standby tasks: [] (org.apache.kafka.streams.processor.internals.StreamThread:199) [2017-05-24 15:26:17,018] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] State transition from RUNNING to PARTITIONS_REVOKED. (org.apache.kafka.streams.processor.internals.StreamThread:972) [2017-05-24 15:26:17,018] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] suspendTasksAndState: suspending all active tasks [0_0, 0_1, 0_2] and standby tasks [] (org.apache.kafka.streams.processor.internals.StreamThread:1097) [2017-05-24 15:26:17,019] DEBUG task [0_0] Suspending (org.apache.kafka.streams.processor.internals.StreamTask:351) [2017-05-24 15:26:17,019] DEBUG task [0_0] Closing processor topology (org.apache.kafka.streams.processor.internals.StreamTask:359) [2017-05-24 15:26:17,023] DEBUG task [0_0] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134) [2017-05-24 15:26:17,026] DEBUG task [0_0] Committing offsets (org.apache.kafka.streams.processor.internals.StreamTask:285) [2017-05-24 15:26:17,029] DEBUG task [0_1] Suspending (org.apache.kafka.streams.processor.internals.StreamTask:351) [2017-05-24 15:26:17,029] DEBUG task [0_1] Closing processor topology (org.apache.kafka.streams.processor.internals.StreamTask:359) [2017-05-24 15:26:17,029] DEBUG task [0_1] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134) [2017-05-24 15:26:17,030] DEBUG task [0_1] Committing offsets (org.apache.kafka.streams.processor.internals.StreamTask:285) [2017-05-24 15:26:17,031] DEBUG task [0_2] Suspending (org.apache.kafka.streams.processor.internals.StreamTask:351) [2017-05-24 15:26:17,031] DEBUG task [0_2] Closing processor topology (org.apache.kafka.streams.processor.internals.StreamTask:359) [2017-05-24 15:26:17,031] DEBUG task [0_2] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134) [2017-05-24 15:26:17,032] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Updating suspended tasks to contain active tasks [0_0, 0_1, 0_2] (org.apache.kafka.streams.processor.internals.StreamThread:1391) [2017-05-24 15:26:17,032] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Removing all active tasks [0_0, 0_1, 0_2] (org.apache.kafka.streams.processor.internals.StreamThread:1398) [2017-05-24 15:26:17,032] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Removing all standby tasks [] (org.apache.kafka.streams.processor.internals.StreamThread:1412) [2017-05-24 15:26:17,032] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] partition revocation took 14 ms. suspended active tasks: [0_0, 0_1, 0_2] suspended standby tasks: [] previous active tasks: [0_0, 0_1, 0_2] (org.apache.kafka.streams.processor.internals.StreamThread:221) [2017-05-24 15:26:17,032] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] found [us.Trigger] topics possibly matching regex (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:258) [2017-05-24 15:26:17,032] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] updating builder with SubscriptionUpdates{updatedTopicSubscriptions=[us.Trigger]} topic(s) with possible matching regex subscription(s) (org.apache.kafka.streams.processor.TopologyBuilder:1550) [2017-05-24 15:26:17,032] DEBUG nodeToSourceTopics {KSTREAM-SOURCE-0000000000=[us.Trigger]} (org.apache.kafka.streams.processor.TopologyBuilder:1371) [2017-05-24 15:26:17,034] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Constructed client metadata {df1e3cfa-5620-4a81-89bf-88ed14115321=ClientMetadata{hostInfo=null, consumers=[reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1-consumer-80f30e19-73f9-40ee-9f59-8b65daed004c], state=[activeTasks: ([]) standbyTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1]}, 8882e71b-7b0f-4341-8447-8b056415bcb9=ClientMetadata{hostInfo=null, consumers=[reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1-consumer-07122eac-9a4e-4cd0-8821-d9a901c4608c], state=[activeTasks: ([]) standbyTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([0_0, 0_1, 0_2]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1]}} from the member subscriptions. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:310) [2017-05-24 15:26:17,034] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Starting to validate internal topics in partition assignor. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:617) [2017-05-24 15:26:17,035] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Completed validating internal topics in partition assignor (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:651) [2017-05-24 15:26:17,035] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Created repartition topics [] from the parsed topology. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:396) [2017-05-24 15:26:17,035] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Starting to validate internal topics in partition assignor. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:617) [2017-05-24 15:26:17,035] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Completed validating internal topics in partition assignor (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:651) [2017-05-24 15:26:17,035] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Created state changelog topics {} from the parsed topology. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:471) [2017-05-24 15:26:17,036] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Assigning tasks [0_0, 0_1, 0_2] to clients {df1e3cfa-5620-4a81-89bf-88ed14115321=[activeTasks: ([]) standbyTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1], 8882e71b-7b0f-4341-8447-8b056415bcb9=[activeTasks: ([]) standbyTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([0_0, 0_1, 0_2]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1]} with number of replicas 0 (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:481) [2017-05-24 15:26:17,036] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Assigned tasks to clients as {df1e3cfa-5620-4a81-89bf-88ed14115321=[activeTasks: ([0_1]) standbyTasks: ([]) assignedTasks: ([0_1]) prevActiveTasks: ([]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1], 8882e71b-7b0f-4341-8447-8b056415bcb9=[activeTasks: ([0_0, 0_2]) standbyTasks: ([]) assignedTasks: ([0_0, 0_2]) prevActiveTasks: ([0_0, 0_1, 0_2]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1]}. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:487) [2017-05-24 15:26:17,038] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] at state PARTITIONS_REVOKED: new partitions [us.Trigger-2, us.Trigger-0] assigned at the end of consumer rebalance. assigned active tasks: [0_0, 0_2] assigned standby tasks: [] current suspended active tasks: [0_0, 0_1, 0_2] current suspended standby tasks: [] previous active tasks: [0_0, 0_1, 0_2] (org.apache.kafka.streams.processor.internals.StreamThread:154) [2017-05-24 15:26:17,038] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] State transition from PARTITIONS_REVOKED to ASSIGNING_PARTITIONS. (org.apache.kafka.streams.processor.internals.StreamThread:972) [2017-05-24 15:26:17,038] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Closing suspended non-assigned active task 0_1 (org.apache.kafka.streams.processor.internals.StreamThread:1189) [2017-05-24 15:26:17,038] DEBUG task [0_1] Closing (org.apache.kafka.streams.processor.internals.StreamTask:398) [2017-05-24 15:26:17,038] DEBUG task [0_1] Suspending (org.apache.kafka.streams.processor.internals.StreamTask:351) [2017-05-24 15:26:17,038] DEBUG task [0_1] Closing processor topology (org.apache.kafka.streams.processor.internals.StreamTask:359) [2017-05-24 15:26:17,038] DEBUG task [0_1] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134) [2017-05-24 15:26:17,041] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Released state dir lock for task 0_1 (org.apache.kafka.streams.processor.internals.StateDirectory:191) [2017-05-24 15:26:17,044] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Adding assigned tasks as active {0_0=[us.Trigger-0], 0_2=[us.Trigger-2]} (org.apache.kafka.streams.processor.internals.StreamThread:1271) [2017-05-24 15:26:17,044] DEBUG task [0_0] Resuming (org.apache.kafka.streams.processor.internals.StreamTask:157) [2017-05-24 15:26:17,044] DEBUG task [0_0] Initializing processor nodes of the topology (org.apache.kafka.streams.processor.internals.StreamTask:316) [2017-05-24 15:26:17,047] DEBUG task [0_2] Resuming (org.apache.kafka.streams.processor.internals.StreamTask:157) [2017-05-24 15:26:17,047] DEBUG task [0_2] Initializing processor nodes of the topology (org.apache.kafka.streams.processor.internals.StreamTask:316) [2017-05-24 15:26:17,050] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] New active tasks to be created: {} (org.apache.kafka.streams.processor.internals.StreamThread:1302) [2017-05-24 15:26:17,051] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Starting restoring state stores from changelog topics [] (org.apache.kafka.streams.processor.internals.StoreChangelogReader:121) [2017-05-24 15:26:17,051] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Took 0 ms to restore all active states (org.apache.kafka.streams.processor.internals.StoreChangelogReader:156) [2017-05-24 15:26:17,051] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Adding assigned standby tasks {0_0=[us.Trigger-0], 0_2=[us.Trigger-2]} (org.apache.kafka.streams.processor.internals.StreamThread:1336) [2017-05-24 15:26:17,051] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] New standby tasks to be created: {} (org.apache.kafka.streams.processor.internals.StreamThread:1355) [2017-05-24 15:26:17,051] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] State transition from ASSIGNING_PARTITIONS to RUNNING. (org.apache.kafka.streams.processor.internals.StreamThread:972) [2017-05-24 15:26:17,051] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] partition assignment took 13 ms. current active tasks: [0_0, 0_2] current standby tasks: [] (org.apache.kafka.streams.processor.internals.StreamThread:187) [2017-05-24 15:26:20,116] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] at state RUNNING: partitions [us.Trigger-2, us.Trigger-0] revoked at the beginning of consumer rebalance. current assigned active tasks: [0_0, 0_2] current assigned standby tasks: [] (org.apache.kafka.streams.processor.internals.StreamThread:199) [2017-05-24 15:26:20,116] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] State transition from RUNNING to PARTITIONS_REVOKED. (org.apache.kafka.streams.processor.internals.StreamThread:972) [2017-05-24 15:26:20,116] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] suspendTasksAndState: suspending all active tasks [0_0, 0_2] and standby tasks [] (org.apache.kafka.streams.processor.internals.StreamThread:1097) [2017-05-24 15:26:20,116] DEBUG task [0_0] Suspending (org.apache.kafka.streams.processor.internals.StreamTask:351) [2017-05-24 15:26:20,116] DEBUG task [0_0] Closing processor topology (org.apache.kafka.streams.processor.internals.StreamTask:359) [2017-05-24 15:26:20,119] DEBUG task [0_0] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134) [2017-05-24 15:26:20,121] DEBUG task [0_2] Suspending (org.apache.kafka.streams.processor.internals.StreamTask:351) [2017-05-24 15:26:20,121] DEBUG task [0_2] Closing processor topology (org.apache.kafka.streams.processor.internals.StreamTask:359) [2017-05-24 15:26:20,121] DEBUG task [0_2] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134) [2017-05-24 15:26:20,122] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Updating suspended tasks to contain active tasks [0_0, 0_2] (org.apache.kafka.streams.processor.internals.StreamThread:1391) [2017-05-24 15:26:20,122] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Removing all active tasks [0_0, 0_2] (org.apache.kafka.streams.processor.internals.StreamThread:1398) [2017-05-24 15:26:20,122] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Removing all standby tasks [] (org.apache.kafka.streams.processor.internals.StreamThread:1412) [2017-05-24 15:26:20,122] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] partition revocation took 6 ms. suspended active tasks: [0_0, 0_2] suspended standby tasks: [] previous active tasks: [0_0, 0_2] (org.apache.kafka.streams.processor.internals.StreamThread:221) [2017-05-24 15:26:20,123] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] found [us.Trigger] topics possibly matching regex (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:258) [2017-05-24 15:26:20,123] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] updating builder with SubscriptionUpdates{updatedTopicSubscriptions=[us.Trigger]} topic(s) with possible matching regex subscription(s) (org.apache.kafka.streams.processor.TopologyBuilder:1550) [2017-05-24 15:26:20,123] DEBUG nodeToSourceTopics {KSTREAM-SOURCE-0000000000=[us.Trigger]} (org.apache.kafka.streams.processor.TopologyBuilder:1371) [2017-05-24 15:26:20,136] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Constructed client metadata {df1e3cfa-5620-4a81-89bf-88ed14115321=ClientMetadata{hostInfo=null, consumers=[reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1-consumer-80f30e19-73f9-40ee-9f59-8b65daed004c], state=[activeTasks: ([]) standbyTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([0_1]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1]}, ad7dab9f-1512-4ff4-9be6-a0059391714f=ClientMetadata{hostInfo=null, consumers=[reballancing-test-ad7dab9f-1512-4ff4-9be6-a0059391714f-StreamThread-1-consumer-4ed0a44d-47ce-4c4f-9ecf-448a58652267], state=[activeTasks: ([]) standbyTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1]}, 8882e71b-7b0f-4341-8447-8b056415bcb9=ClientMetadata{hostInfo=null, consumers=[reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1-consumer-07122eac-9a4e-4cd0-8821-d9a901c4608c], state=[activeTasks: ([]) standbyTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([0_0, 0_2]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1]}} from the member subscriptions. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:310) [2017-05-24 15:26:20,136] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Starting to validate internal topics in partition assignor. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:617) [2017-05-24 15:26:20,136] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Completed validating internal topics in partition assignor (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:651) [2017-05-24 15:26:20,136] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Created repartition topics [] from the parsed topology. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:396) [2017-05-24 15:26:20,137] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Starting to validate internal topics in partition assignor. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:617) [2017-05-24 15:26:20,137] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Completed validating internal topics in partition assignor (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:651) [2017-05-24 15:26:20,137] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Created state changelog topics {} from the parsed topology. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:471) [2017-05-24 15:26:20,137] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Assigning tasks [0_0, 0_1, 0_2] to clients {df1e3cfa-5620-4a81-89bf-88ed14115321=[activeTasks: ([]) standbyTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([0_1]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1], ad7dab9f-1512-4ff4-9be6-a0059391714f=[activeTasks: ([]) standbyTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1], 8882e71b-7b0f-4341-8447-8b056415bcb9=[activeTasks: ([]) standbyTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([0_0, 0_2]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1]} with number of replicas 0 (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:481) [2017-05-24 15:26:20,137] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Assigned tasks to clients as {df1e3cfa-5620-4a81-89bf-88ed14115321=[activeTasks: ([0_1]) standbyTasks: ([]) assignedTasks: ([0_1]) prevActiveTasks: ([0_1]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1], ad7dab9f-1512-4ff4-9be6-a0059391714f=[activeTasks: ([0_2]) standbyTasks: ([]) assignedTasks: ([0_2]) prevActiveTasks: ([]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1], 8882e71b-7b0f-4341-8447-8b056415bcb9=[activeTasks: ([0_0]) standbyTasks: ([]) assignedTasks: ([0_0]) prevActiveTasks: ([0_0, 0_2]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1]}. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:487) [2017-05-24 15:26:20,140] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] at state PARTITIONS_REVOKED: new partitions [us.Trigger-0] assigned at the end of consumer rebalance. assigned active tasks: [0_0] assigned standby tasks: [] current suspended active tasks: [0_0, 0_2] current suspended standby tasks: [] previous active tasks: [0_0, 0_2] (org.apache.kafka.streams.processor.internals.StreamThread:154) [2017-05-24 15:26:20,140] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] State transition from PARTITIONS_REVOKED to ASSIGNING_PARTITIONS. (org.apache.kafka.streams.processor.internals.StreamThread:972) [2017-05-24 15:26:20,140] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Closing suspended non-assigned active task 0_2 (org.apache.kafka.streams.processor.internals.StreamThread:1189) [2017-05-24 15:26:20,140] DEBUG task [0_2] Closing (org.apache.kafka.streams.processor.internals.StreamTask:398) [2017-05-24 15:26:20,140] DEBUG task [0_2] Suspending (org.apache.kafka.streams.processor.internals.StreamTask:351) [2017-05-24 15:26:20,140] DEBUG task [0_2] Closing processor topology (org.apache.kafka.streams.processor.internals.StreamTask:359) [2017-05-24 15:26:20,140] DEBUG task [0_2] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134) [2017-05-24 15:26:20,141] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Released state dir lock for task 0_2 (org.apache.kafka.streams.processor.internals.StateDirectory:191) [2017-05-24 15:26:20,141] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Adding assigned tasks as active {0_0=[us.Trigger-0]} (org.apache.kafka.streams.processor.internals.StreamThread:1271) [2017-05-24 15:26:20,141] DEBUG task [0_0] Resuming (org.apache.kafka.streams.processor.internals.StreamTask:157) [2017-05-24 15:26:20,142] DEBUG task [0_0] Initializing processor nodes of the topology (org.apache.kafka.streams.processor.internals.StreamTask:316) [2017-05-24 15:26:20,144] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] New active tasks to be created: {} (org.apache.kafka.streams.processor.internals.StreamThread:1302) [2017-05-24 15:26:20,144] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Starting restoring state stores from changelog topics [] (org.apache.kafka.streams.processor.internals.StoreChangelogReader:121) [2017-05-24 15:26:20,144] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Took 0 ms to restore all active states (org.apache.kafka.streams.processor.internals.StoreChangelogReader:156) [2017-05-24 15:26:20,144] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Adding assigned standby tasks {0_0=[us.Trigger-0]} (org.apache.kafka.streams.processor.internals.StreamThread:1336) [2017-05-24 15:26:20,144] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] New standby tasks to be created: {} (org.apache.kafka.streams.processor.internals.StreamThread:1355) [2017-05-24 15:26:20,145] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] State transition from ASSIGNING_PARTITIONS to RUNNING. (org.apache.kafka.streams.processor.internals.StreamThread:972) [2017-05-24 15:26:20,145] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] partition assignment took 5 ms. current active tasks: [0_0] current standby tasks: [] (org.apache.kafka.streams.processor.internals.StreamThread:187) [2017-05-24 15:26:40,858] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Committing all active tasks [0_0] and standby tasks [] because the commit interval 30000ms has elapsed by 30087ms (org.apache.kafka.streams.processor.internals.StreamThread:767) [2017-05-24 15:26:40,860] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Committing task StreamTask 0_0 (org.apache.kafka.streams.processor.internals.StreamThread:805) [2017-05-24 15:26:40,860] DEBUG task [0_0] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134) [2017-05-24 15:26:40,861] DEBUG task [0_0] Committing offsets (org.apache.kafka.streams.processor.internals.StreamTask:285) [2017-05-24 15:27:10,950] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Committing all active tasks [0_0] and standby tasks [] because the commit interval 30000ms has elapsed by 30089ms (org.apache.kafka.streams.processor.internals.StreamThread:767) [2017-05-24 15:27:10,951] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Committing task StreamTask 0_0 (org.apache.kafka.streams.processor.internals.StreamThread:805) [2017-05-24 15:27:10,951] DEBUG task [0_0] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134) [2017-05-24 15:27:10,953] DEBUG task [0_0] Committing offsets (org.apache.kafka.streams.processor.internals.StreamTask:285) [2017-05-24 15:27:36,797] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] at state RUNNING: partitions [us.Trigger-0] revoked at the beginning of consumer rebalance. current assigned active tasks: [0_0] current assigned standby tasks: [] (org.apache.kafka.streams.processor.internals.StreamThread:199) [2017-05-24 15:27:36,797] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] State transition from RUNNING to PARTITIONS_REVOKED. (org.apache.kafka.streams.processor.internals.StreamThread:972) [2017-05-24 15:27:36,797] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] suspendTasksAndState: suspending all active tasks [0_0] and standby tasks [] (org.apache.kafka.streams.processor.internals.StreamThread:1097) [2017-05-24 15:27:36,798] DEBUG task [0_0] Suspending (org.apache.kafka.streams.processor.internals.StreamTask:351) [2017-05-24 15:27:36,798] DEBUG task [0_0] Closing processor topology (org.apache.kafka.streams.processor.internals.StreamTask:359) [2017-05-24 15:27:36,799] DEBUG task [0_0] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134) [2017-05-24 15:27:36,801] DEBUG task [0_0] Committing offsets (org.apache.kafka.streams.processor.internals.StreamTask:285) [2017-05-24 15:27:36,803] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Updating suspended tasks to contain active tasks [0_0] (org.apache.kafka.streams.processor.internals.StreamThread:1391) [2017-05-24 15:27:36,803] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Removing all active tasks [0_0] (org.apache.kafka.streams.processor.internals.StreamThread:1398) [2017-05-24 15:27:36,803] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Removing all standby tasks [] (org.apache.kafka.streams.processor.internals.StreamThread:1412) [2017-05-24 15:27:36,803] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] partition revocation took 6 ms. suspended active tasks: [0_0] suspended standby tasks: [] previous active tasks: [0_0] (org.apache.kafka.streams.processor.internals.StreamThread:221) [2017-05-24 15:27:36,803] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] found [us.Trigger] topics possibly matching regex (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:258) [2017-05-24 15:27:36,804] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] updating builder with SubscriptionUpdates{updatedTopicSubscriptions=[us.Trigger]} topic(s) with possible matching regex subscription(s) (org.apache.kafka.streams.processor.TopologyBuilder:1550) [2017-05-24 15:27:36,804] DEBUG nodeToSourceTopics {KSTREAM-SOURCE-0000000000=[us.Trigger]} (org.apache.kafka.streams.processor.TopologyBuilder:1371) [2017-05-24 15:27:37,285] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Constructed client metadata {df1e3cfa-5620-4a81-89bf-88ed14115321=ClientMetadata{hostInfo=null, consumers=[reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1-consumer-80f30e19-73f9-40ee-9f59-8b65daed004c], state=[activeTasks: ([]) standbyTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([0_1]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1]}, ad7dab9f-1512-4ff4-9be6-a0059391714f=ClientMetadata{hostInfo=null, consumers=[reballancing-test-ad7dab9f-1512-4ff4-9be6-a0059391714f-StreamThread-1-consumer-4ed0a44d-47ce-4c4f-9ecf-448a58652267], state=[activeTasks: ([]) standbyTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([0_2]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1]}, 8882e71b-7b0f-4341-8447-8b056415bcb9=ClientMetadata{hostInfo=null, consumers=[reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1-consumer-07122eac-9a4e-4cd0-8821-d9a901c4608c], state=[activeTasks: ([]) standbyTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([0_0]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1]}} from the member subscriptions. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:310) [2017-05-24 15:27:37,286] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Starting to validate internal topics in partition assignor. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:617) [2017-05-24 15:27:37,286] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Completed validating internal topics in partition assignor (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:651) [2017-05-24 15:27:37,286] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Created repartition topics [] from the parsed topology. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:396) [2017-05-24 15:27:37,286] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Starting to validate internal topics in partition assignor. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:617) [2017-05-24 15:27:37,287] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Completed validating internal topics in partition assignor (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:651) [2017-05-24 15:27:37,287] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Created state changelog topics {} from the parsed topology. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:471) [2017-05-24 15:27:37,287] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Assigning tasks [0_0, 0_1, 0_2] to clients {df1e3cfa-5620-4a81-89bf-88ed14115321=[activeTasks: ([]) standbyTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([0_1]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1], ad7dab9f-1512-4ff4-9be6-a0059391714f=[activeTasks: ([]) standbyTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([0_2]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1], 8882e71b-7b0f-4341-8447-8b056415bcb9=[activeTasks: ([]) standbyTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([0_0]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1]} with number of replicas 0 (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:481) [2017-05-24 15:27:37,287] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Assigned tasks to clients as {df1e3cfa-5620-4a81-89bf-88ed14115321=[activeTasks: ([0_1]) standbyTasks: ([]) assignedTasks: ([0_1]) prevActiveTasks: ([0_1]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1], ad7dab9f-1512-4ff4-9be6-a0059391714f=[activeTasks: ([0_2]) standbyTasks: ([]) assignedTasks: ([0_2]) prevActiveTasks: ([0_2]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1], 8882e71b-7b0f-4341-8447-8b056415bcb9=[activeTasks: ([0_0]) standbyTasks: ([]) assignedTasks: ([0_0]) prevActiveTasks: ([0_0]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1]}. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:487) [2017-05-24 15:27:37,288] WARN The following subscribed topics are not assigned to any members in the group reballancing-test : [demo.Trigger] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:367) [2017-05-24 15:27:37,289] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] at state PARTITIONS_REVOKED: new partitions [us.Trigger-0] assigned at the end of consumer rebalance. assigned active tasks: [0_0] assigned standby tasks: [] current suspended active tasks: [0_0] current suspended standby tasks: [] previous active tasks: [0_0] (org.apache.kafka.streams.processor.internals.StreamThread:154) [2017-05-24 15:27:37,290] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] State transition from PARTITIONS_REVOKED to ASSIGNING_PARTITIONS. (org.apache.kafka.streams.processor.internals.StreamThread:972) [2017-05-24 15:27:37,290] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Adding assigned tasks as active {0_0=[us.Trigger-0]} (org.apache.kafka.streams.processor.internals.StreamThread:1271) [2017-05-24 15:27:37,290] DEBUG task [0_0] Resuming (org.apache.kafka.streams.processor.internals.StreamTask:157) [2017-05-24 15:27:37,290] DEBUG task [0_0] Initializing processor nodes of the topology (org.apache.kafka.streams.processor.internals.StreamTask:316) [2017-05-24 15:27:37,292] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] New active tasks to be created: {} (org.apache.kafka.streams.processor.internals.StreamThread:1302) [2017-05-24 15:27:37,292] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Starting restoring state stores from changelog topics [] (org.apache.kafka.streams.processor.internals.StoreChangelogReader:121) [2017-05-24 15:27:37,293] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Took 1 ms to restore all active states (org.apache.kafka.streams.processor.internals.StoreChangelogReader:156) [2017-05-24 15:27:37,293] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Adding assigned standby tasks {0_0=[us.Trigger-0]} (org.apache.kafka.streams.processor.internals.StreamThread:1336) [2017-05-24 15:27:37,293] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] New standby tasks to be created: {} (org.apache.kafka.streams.processor.internals.StreamThread:1355) [2017-05-24 15:27:37,293] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] State transition from ASSIGNING_PARTITIONS to RUNNING. (org.apache.kafka.streams.processor.internals.StreamThread:972) [2017-05-24 15:27:37,293] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] partition assignment took 3 ms. current active tasks: [0_0] current standby tasks: [] (org.apache.kafka.streams.processor.internals.StreamThread:187) [2017-05-24 15:27:37,293] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] at state RUNNING: partitions [us.Trigger-0] revoked at the beginning of consumer rebalance. current assigned active tasks: [0_0] current assigned standby tasks: [] (org.apache.kafka.streams.processor.internals.StreamThread:199) [2017-05-24 15:27:37,293] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] State transition from RUNNING to PARTITIONS_REVOKED. (org.apache.kafka.streams.processor.internals.StreamThread:972) [2017-05-24 15:27:37,293] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] suspendTasksAndState: suspending all active tasks [0_0] and standby tasks [] (org.apache.kafka.streams.processor.internals.StreamThread:1097) [2017-05-24 15:27:37,294] DEBUG task [0_0] Suspending (org.apache.kafka.streams.processor.internals.StreamTask:351) [2017-05-24 15:27:37,294] DEBUG task [0_0] Closing processor topology (org.apache.kafka.streams.processor.internals.StreamTask:359) [2017-05-24 15:27:37,295] DEBUG task [0_0] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134) [2017-05-24 15:27:37,297] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Updating suspended tasks to contain active tasks [0_0] (org.apache.kafka.streams.processor.internals.StreamThread:1391) [2017-05-24 15:27:37,297] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Removing all active tasks [0_0] (org.apache.kafka.streams.processor.internals.StreamThread:1398) [2017-05-24 15:27:37,297] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Removing all standby tasks [] (org.apache.kafka.streams.processor.internals.StreamThread:1412) [2017-05-24 15:27:37,297] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] partition revocation took 4 ms. suspended active tasks: [0_0] suspended standby tasks: [] previous active tasks: [0_0] (org.apache.kafka.streams.processor.internals.StreamThread:221) [2017-05-24 15:27:37,298] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] found [us.Trigger, demo.Trigger] topics possibly matching regex (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:258) [2017-05-24 15:27:37,298] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] updating builder with SubscriptionUpdates{updatedTopicSubscriptions=[us.Trigger, demo.Trigger]} topic(s) with possible matching regex subscription(s) (org.apache.kafka.streams.processor.TopologyBuilder:1550) [2017-05-24 15:27:37,298] DEBUG nodeToSourceTopics {KSTREAM-SOURCE-0000000000=[us.Trigger, demo.Trigger]} (org.apache.kafka.streams.processor.TopologyBuilder:1371) [2017-05-24 15:27:40,323] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Constructed client metadata {df1e3cfa-5620-4a81-89bf-88ed14115321=ClientMetadata{hostInfo=null, consumers=[reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1-consumer-80f30e19-73f9-40ee-9f59-8b65daed004c], state=[activeTasks: ([]) standbyTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([0_1]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1]}, ad7dab9f-1512-4ff4-9be6-a0059391714f=ClientMetadata{hostInfo=null, consumers=[reballancing-test-ad7dab9f-1512-4ff4-9be6-a0059391714f-StreamThread-1-consumer-4ed0a44d-47ce-4c4f-9ecf-448a58652267], state=[activeTasks: ([]) standbyTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([0_2]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1]}, 8882e71b-7b0f-4341-8447-8b056415bcb9=ClientMetadata{hostInfo=null, consumers=[reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1-consumer-07122eac-9a4e-4cd0-8821-d9a901c4608c], state=[activeTasks: ([]) standbyTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([0_0]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1]}} from the member subscriptions. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:310) [2017-05-24 15:27:40,323] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Starting to validate internal topics in partition assignor. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:617) [2017-05-24 15:27:40,323] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Completed validating internal topics in partition assignor (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:651) [2017-05-24 15:27:40,323] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Created repartition topics [] from the parsed topology. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:396) [2017-05-24 15:27:40,323] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Starting to validate internal topics in partition assignor. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:617) [2017-05-24 15:27:40,323] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Completed validating internal topics in partition assignor (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:651) [2017-05-24 15:27:40,323] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Created state changelog topics {} from the parsed topology. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:471) [2017-05-24 15:27:40,324] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Assigning tasks [0_0, 0_1, 0_2] to clients {df1e3cfa-5620-4a81-89bf-88ed14115321=[activeTasks: ([]) standbyTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([0_1]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1], ad7dab9f-1512-4ff4-9be6-a0059391714f=[activeTasks: ([]) standbyTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([0_2]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1], 8882e71b-7b0f-4341-8447-8b056415bcb9=[activeTasks: ([]) standbyTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([0_0]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1]} with number of replicas 0 (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:481) [2017-05-24 15:27:40,324] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Assigned tasks to clients as {df1e3cfa-5620-4a81-89bf-88ed14115321=[activeTasks: ([0_1]) standbyTasks: ([]) assignedTasks: ([0_1]) prevActiveTasks: ([0_1]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1], ad7dab9f-1512-4ff4-9be6-a0059391714f=[activeTasks: ([0_2]) standbyTasks: ([]) assignedTasks: ([0_2]) prevActiveTasks: ([0_2]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1], 8882e71b-7b0f-4341-8447-8b056415bcb9=[activeTasks: ([0_0]) standbyTasks: ([]) assignedTasks: ([0_0]) prevActiveTasks: ([0_0]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1]}. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:487) [2017-05-24 15:27:40,325] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] at state PARTITIONS_REVOKED: new partitions [us.Trigger-0, demo.Trigger-0] assigned at the end of consumer rebalance. assigned active tasks: [0_0] assigned standby tasks: [] current suspended active tasks: [0_0] current suspended standby tasks: [] previous active tasks: [0_0] (org.apache.kafka.streams.processor.internals.StreamThread:154) [2017-05-24 15:27:40,326] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] State transition from PARTITIONS_REVOKED to ASSIGNING_PARTITIONS. (org.apache.kafka.streams.processor.internals.StreamThread:972) [2017-05-24 15:27:40,326] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Closing suspended non-assigned active task 0_0 (org.apache.kafka.streams.processor.internals.StreamThread:1189) [2017-05-24 15:27:40,326] DEBUG task [0_0] Closing (org.apache.kafka.streams.processor.internals.StreamTask:398) [2017-05-24 15:27:40,326] DEBUG task [0_0] Suspending (org.apache.kafka.streams.processor.internals.StreamTask:351) [2017-05-24 15:27:40,326] DEBUG task [0_0] Closing processor topology (org.apache.kafka.streams.processor.internals.StreamTask:359) [2017-05-24 15:27:40,326] DEBUG task [0_0] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134) [2017-05-24 15:27:40,327] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Released state dir lock for task 0_0 (org.apache.kafka.streams.processor.internals.StateDirectory:191) [2017-05-24 15:27:40,327] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Adding assigned tasks as active {0_0=[us.Trigger-0, demo.Trigger-0]} (org.apache.kafka.streams.processor.internals.StreamThread:1271) [2017-05-24 15:27:40,328] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] New active tasks to be created: {0_0=[us.Trigger-0, demo.Trigger-0]} (org.apache.kafka.streams.processor.internals.StreamThread:1302) [2017-05-24 15:27:40,328] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Creating active task 0_0 with assigned partitions [[us.Trigger-0, demo.Trigger-0]] (org.apache.kafka.streams.processor.internals.StreamThread:1221) [2017-05-24 15:27:40,328] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Acquired state dir lock for task 0_0 (org.apache.kafka.streams.processor.internals.StateDirectory:135) [2017-05-24 15:27:40,329] INFO task [0_0] Created state store manager for task 0_0 with the acquired state dir lock (org.apache.kafka.streams.processor.internals.ProcessorStateManager:122) [2017-05-24 15:27:40,329] DEBUG task [0_0] Initializing (org.apache.kafka.streams.processor.internals.StreamTask:138) [2017-05-24 15:27:40,329] DEBUG task [0_0] Initializing state stores (org.apache.kafka.streams.processor.internals.AbstractTask:194) [2017-05-24 15:27:40,329] DEBUG task [0_0] Updating store offset limits {} (org.apache.kafka.streams.processor.internals.AbstractTask:171) [2017-05-24 15:27:40,330] INFO task [0_0] Register global stores [] (org.apache.kafka.streams.processor.internals.ProcessorStateManager:352) [2017-05-24 15:27:40,330] DEBUG task [0_0] Initializing processor nodes of the topology (org.apache.kafka.streams.processor.internals.StreamTask:316) [2017-05-24 15:27:40,331] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Created active task 0_0 with assigned partitions [us.Trigger-0, demo.Trigger-0] (org.apache.kafka.streams.processor.internals.StreamThread:1240) [2017-05-24 15:27:40,332] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Starting restoring state stores from changelog topics [] (org.apache.kafka.streams.processor.internals.StoreChangelogReader:121) [2017-05-24 15:27:40,332] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Took 0 ms to restore all active states (org.apache.kafka.streams.processor.internals.StoreChangelogReader:156) [2017-05-24 15:27:40,332] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Adding assigned standby tasks {0_0=[us.Trigger-0, demo.Trigger-0]} (org.apache.kafka.streams.processor.internals.StreamThread:1336) [2017-05-24 15:27:40,332] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] New standby tasks to be created: {} (org.apache.kafka.streams.processor.internals.StreamThread:1355) [2017-05-24 15:27:40,332] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] State transition from ASSIGNING_PARTITIONS to RUNNING. (org.apache.kafka.streams.processor.internals.StreamThread:972) [2017-05-24 15:27:40,332] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] partition assignment took 6 ms. current active tasks: [0_0] current standby tasks: [] (org.apache.kafka.streams.processor.internals.StreamThread:187) [2017-05-24 15:27:40,950] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Committing all active tasks [0_0] and standby tasks [] because the commit interval 30000ms has elapsed by 30003ms (org.apache.kafka.streams.processor.internals.StreamThread:767) [2017-05-24 15:27:40,950] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Committing task StreamTask 0_0 (org.apache.kafka.streams.processor.internals.StreamThread:805) [2017-05-24 15:27:40,950] DEBUG task [0_0] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134) [2017-05-24 15:27:40,952] DEBUG task [0_0] Committing offsets (org.apache.kafka.streams.processor.internals.StreamTask:285) [2017-05-24 15:28:11,043] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Committing all active tasks [0_0] and standby tasks [] because the commit interval 30000ms has elapsed by 30093ms (org.apache.kafka.streams.processor.internals.StreamThread:767) [2017-05-24 15:28:11,043] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Committing task StreamTask 0_0 (org.apache.kafka.streams.processor.internals.StreamThread:805) [2017-05-24 15:28:11,043] DEBUG task [0_0] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134) [2017-05-24 15:28:11,045] DEBUG task [0_0] Committing offsets (org.apache.kafka.streams.processor.internals.StreamTask:285) [2017-05-24 15:28:41,135] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Committing all active tasks [0_0] and standby tasks [] because the commit interval 30000ms has elapsed by 30090ms (org.apache.kafka.streams.processor.internals.StreamThread:767) [2017-05-24 15:28:41,135] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Committing task StreamTask 0_0 (org.apache.kafka.streams.processor.internals.StreamThread:805) [2017-05-24 15:28:41,135] DEBUG task [0_0] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134) [2017-05-24 15:28:41,137] DEBUG task [0_0] Committing offsets (org.apache.kafka.streams.processor.internals.StreamTask:285) [2017-05-24 15:29:11,144] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Committing all active tasks [0_0] and standby tasks [] because the commit interval 30000ms has elapsed by 30011ms (org.apache.kafka.streams.processor.internals.StreamThread:767) [2017-05-24 15:29:11,145] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Committing task StreamTask 0_0 (org.apache.kafka.streams.processor.internals.StreamThread:805) [2017-05-24 15:29:11,145] DEBUG task [0_0] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134) [2017-05-24 15:29:41,152] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Committing all active tasks [0_0] and standby tasks [] because the commit interval 30000ms has elapsed by 30008ms (org.apache.kafka.streams.processor.internals.StreamThread:767) [2017-05-24 15:29:41,152] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Committing task StreamTask 0_0 (org.apache.kafka.streams.processor.internals.StreamThread:805) [2017-05-24 15:29:41,153] DEBUG task [0_0] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134) [2017-05-24 15:30:11,163] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Committing all active tasks [0_0] and standby tasks [] because the commit interval 30000ms has elapsed by 30007ms (org.apache.kafka.streams.processor.internals.StreamThread:767) [2017-05-24 15:30:11,163] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Committing task StreamTask 0_0 (org.apache.kafka.streams.processor.internals.StreamThread:805) [2017-05-24 15:30:11,163] DEBUG task [0_0] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134) [2017-05-24 15:30:11,165] DEBUG task [0_0] Committing offsets (org.apache.kafka.streams.processor.internals.StreamTask:285) [2017-05-24 15:30:14,023] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] at state RUNNING: partitions [us.Trigger-0, demo.Trigger-0] revoked at the beginning of consumer rebalance. current assigned active tasks: [0_0] current assigned standby tasks: [] (org.apache.kafka.streams.processor.internals.StreamThread:199) [2017-05-24 15:30:14,023] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] State transition from RUNNING to PARTITIONS_REVOKED. (org.apache.kafka.streams.processor.internals.StreamThread:972) [2017-05-24 15:30:14,024] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] suspendTasksAndState: suspending all active tasks [0_0] and standby tasks [] (org.apache.kafka.streams.processor.internals.StreamThread:1097) [2017-05-24 15:30:14,024] DEBUG task [0_0] Suspending (org.apache.kafka.streams.processor.internals.StreamTask:351) [2017-05-24 15:30:14,024] DEBUG task [0_0] Closing processor topology (org.apache.kafka.streams.processor.internals.StreamTask:359) [2017-05-24 15:30:14,025] DEBUG task [0_0] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134) [2017-05-24 15:30:14,026] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Updating suspended tasks to contain active tasks [0_0] (org.apache.kafka.streams.processor.internals.StreamThread:1391) [2017-05-24 15:30:14,027] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Removing all active tasks [0_0] (org.apache.kafka.streams.processor.internals.StreamThread:1398) [2017-05-24 15:30:14,027] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Removing all standby tasks [] (org.apache.kafka.streams.processor.internals.StreamThread:1412) [2017-05-24 15:30:14,027] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] partition revocation took 4 ms. suspended active tasks: [0_0] suspended standby tasks: [] previous active tasks: [0_0] (org.apache.kafka.streams.processor.internals.StreamThread:221) [2017-05-24 15:30:14,027] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] found [foo.Trigger, us.Trigger, demo.Trigger] topics possibly matching regex (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:258) [2017-05-24 15:30:14,027] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] updating builder with SubscriptionUpdates{updatedTopicSubscriptions=[foo.Trigger, us.Trigger, demo.Trigger]} topic(s) with possible matching regex subscription(s) (org.apache.kafka.streams.processor.TopologyBuilder:1550) [2017-05-24 15:30:14,027] DEBUG nodeToSourceTopics {KSTREAM-SOURCE-0000000000=[foo.Trigger, us.Trigger, demo.Trigger]} (org.apache.kafka.streams.processor.TopologyBuilder:1371) [2017-05-24 15:30:14,369] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Constructed client metadata {df1e3cfa-5620-4a81-89bf-88ed14115321=ClientMetadata{hostInfo=null, consumers=[reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1-consumer-80f30e19-73f9-40ee-9f59-8b65daed004c], state=[activeTasks: ([]) standbyTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([0_1]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1]}, ad7dab9f-1512-4ff4-9be6-a0059391714f=ClientMetadata{hostInfo=null, consumers=[reballancing-test-ad7dab9f-1512-4ff4-9be6-a0059391714f-StreamThread-1-consumer-4ed0a44d-47ce-4c4f-9ecf-448a58652267], state=[activeTasks: ([]) standbyTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([0_2]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1]}, 8882e71b-7b0f-4341-8447-8b056415bcb9=ClientMetadata{hostInfo=null, consumers=[reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1-consumer-07122eac-9a4e-4cd0-8821-d9a901c4608c], state=[activeTasks: ([]) standbyTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([0_0]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1]}} from the member subscriptions. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:310) [2017-05-24 15:30:14,369] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Starting to validate internal topics in partition assignor. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:617) [2017-05-24 15:30:14,369] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Completed validating internal topics in partition assignor (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:651) [2017-05-24 15:30:14,369] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Created repartition topics [] from the parsed topology. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:396) [2017-05-24 15:30:14,369] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Starting to validate internal topics in partition assignor. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:617) [2017-05-24 15:30:14,369] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Completed validating internal topics in partition assignor (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:651) [2017-05-24 15:30:14,370] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Created state changelog topics {} from the parsed topology. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:471) [2017-05-24 15:30:14,370] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Assigning tasks [0_0, 0_1, 0_2] to clients {df1e3cfa-5620-4a81-89bf-88ed14115321=[activeTasks: ([]) standbyTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([0_1]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1], ad7dab9f-1512-4ff4-9be6-a0059391714f=[activeTasks: ([]) standbyTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([0_2]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1], 8882e71b-7b0f-4341-8447-8b056415bcb9=[activeTasks: ([]) standbyTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([0_0]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1]} with number of replicas 0 (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:481) [2017-05-24 15:30:14,370] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Assigned tasks to clients as {df1e3cfa-5620-4a81-89bf-88ed14115321=[activeTasks: ([0_1]) standbyTasks: ([]) assignedTasks: ([0_1]) prevActiveTasks: ([0_1]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1], ad7dab9f-1512-4ff4-9be6-a0059391714f=[activeTasks: ([0_2]) standbyTasks: ([]) assignedTasks: ([0_2]) prevActiveTasks: ([0_2]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1], 8882e71b-7b0f-4341-8447-8b056415bcb9=[activeTasks: ([0_0]) standbyTasks: ([]) assignedTasks: ([0_0]) prevActiveTasks: ([0_0]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1]}. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:487) [2017-05-24 15:30:14,371] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] at state PARTITIONS_REVOKED: new partitions [foo.Trigger-0, us.Trigger-0, demo.Trigger-0] assigned at the end of consumer rebalance. assigned active tasks: [0_0] assigned standby tasks: [] current suspended active tasks: [0_0] current suspended standby tasks: [] previous active tasks: [0_0] (org.apache.kafka.streams.processor.internals.StreamThread:154) [2017-05-24 15:30:14,371] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] State transition from PARTITIONS_REVOKED to ASSIGNING_PARTITIONS. (org.apache.kafka.streams.processor.internals.StreamThread:972) [2017-05-24 15:30:14,372] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Closing suspended non-assigned active task 0_0 (org.apache.kafka.streams.processor.internals.StreamThread:1189) [2017-05-24 15:30:14,372] DEBUG task [0_0] Closing (org.apache.kafka.streams.processor.internals.StreamTask:398) [2017-05-24 15:30:14,372] DEBUG task [0_0] Suspending (org.apache.kafka.streams.processor.internals.StreamTask:351) [2017-05-24 15:30:14,372] DEBUG task [0_0] Closing processor topology (org.apache.kafka.streams.processor.internals.StreamTask:359) [2017-05-24 15:30:14,372] DEBUG task [0_0] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134) [2017-05-24 15:30:14,373] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Released state dir lock for task 0_0 (org.apache.kafka.streams.processor.internals.StateDirectory:191) [2017-05-24 15:30:14,373] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Adding assigned tasks as active {0_0=[foo.Trigger-0, us.Trigger-0, demo.Trigger-0]} (org.apache.kafka.streams.processor.internals.StreamThread:1271) [2017-05-24 15:30:14,373] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] New active tasks to be created: {0_0=[foo.Trigger-0, us.Trigger-0, demo.Trigger-0]} (org.apache.kafka.streams.processor.internals.StreamThread:1302) [2017-05-24 15:30:14,373] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Creating active task 0_0 with assigned partitions [[foo.Trigger-0, us.Trigger-0, demo.Trigger-0]] (org.apache.kafka.streams.processor.internals.StreamThread:1221) [2017-05-24 15:30:14,374] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Acquired state dir lock for task 0_0 (org.apache.kafka.streams.processor.internals.StateDirectory:135) [2017-05-24 15:30:14,374] INFO task [0_0] Created state store manager for task 0_0 with the acquired state dir lock (org.apache.kafka.streams.processor.internals.ProcessorStateManager:122) [2017-05-24 15:30:14,374] DEBUG task [0_0] Initializing (org.apache.kafka.streams.processor.internals.StreamTask:138) [2017-05-24 15:30:14,374] DEBUG task [0_0] Initializing state stores (org.apache.kafka.streams.processor.internals.AbstractTask:194) [2017-05-24 15:30:14,374] DEBUG task [0_0] Updating store offset limits {} (org.apache.kafka.streams.processor.internals.AbstractTask:171) [2017-05-24 15:30:14,375] INFO task [0_0] Register global stores [] (org.apache.kafka.streams.processor.internals.ProcessorStateManager:352) [2017-05-24 15:30:14,375] DEBUG task [0_0] Initializing processor nodes of the topology (org.apache.kafka.streams.processor.internals.StreamTask:316) [2017-05-24 15:30:14,376] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Created active task 0_0 with assigned partitions [foo.Trigger-0, us.Trigger-0, demo.Trigger-0] (org.apache.kafka.streams.processor.internals.StreamThread:1240) [2017-05-24 15:30:14,376] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Starting restoring state stores from changelog topics [] (org.apache.kafka.streams.processor.internals.StoreChangelogReader:121) [2017-05-24 15:30:14,376] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Took 0 ms to restore all active states (org.apache.kafka.streams.processor.internals.StoreChangelogReader:156) [2017-05-24 15:30:14,376] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Adding assigned standby tasks {0_0=[foo.Trigger-0, us.Trigger-0, demo.Trigger-0]} (org.apache.kafka.streams.processor.internals.StreamThread:1336) [2017-05-24 15:30:14,376] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] New standby tasks to be created: {} (org.apache.kafka.streams.processor.internals.StreamThread:1355) [2017-05-24 15:30:14,376] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] State transition from ASSIGNING_PARTITIONS to RUNNING. (org.apache.kafka.streams.processor.internals.StreamThread:972) [2017-05-24 15:30:14,376] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] partition assignment took 5 ms. current active tasks: [0_0] current standby tasks: [] (org.apache.kafka.streams.processor.internals.StreamThread:187) [2017-05-24 15:30:26,652] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] at state RUNNING: partitions [foo.Trigger-0, us.Trigger-0, demo.Trigger-0] revoked at the beginning of consumer rebalance. current assigned active tasks: [0_0] current assigned standby tasks: [] (org.apache.kafka.streams.processor.internals.StreamThread:199) [2017-05-24 15:30:26,652] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] State transition from RUNNING to PARTITIONS_REVOKED. (org.apache.kafka.streams.processor.internals.StreamThread:972) [2017-05-24 15:30:26,652] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] suspendTasksAndState: suspending all active tasks [0_0] and standby tasks [] (org.apache.kafka.streams.processor.internals.StreamThread:1097) [2017-05-24 15:30:26,652] DEBUG task [0_0] Suspending (org.apache.kafka.streams.processor.internals.StreamTask:351) [2017-05-24 15:30:26,653] DEBUG task [0_0] Closing processor topology (org.apache.kafka.streams.processor.internals.StreamTask:359) [2017-05-24 15:30:26,653] DEBUG task [0_0] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134) [2017-05-24 15:30:26,655] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Updating suspended tasks to contain active tasks [0_0] (org.apache.kafka.streams.processor.internals.StreamThread:1391) [2017-05-24 15:30:26,655] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Removing all active tasks [0_0] (org.apache.kafka.streams.processor.internals.StreamThread:1398) [2017-05-24 15:30:26,655] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Removing all standby tasks [] (org.apache.kafka.streams.processor.internals.StreamThread:1412) [2017-05-24 15:30:26,655] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] partition revocation took 3 ms. suspended active tasks: [0_0] suspended standby tasks: [] previous active tasks: [0_0] (org.apache.kafka.streams.processor.internals.StreamThread:221) [2017-05-24 15:30:26,655] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] found [foo.Trigger, us.Trigger, demo.Trigger] topics possibly matching regex (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:258) [2017-05-24 15:30:26,655] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] updating builder with SubscriptionUpdates{updatedTopicSubscriptions=[foo.Trigger, us.Trigger, demo.Trigger]} topic(s) with possible matching regex subscription(s) (org.apache.kafka.streams.processor.TopologyBuilder:1550) [2017-05-24 15:30:26,655] DEBUG nodeToSourceTopics {KSTREAM-SOURCE-0000000000=[foo.Trigger, us.Trigger, demo.Trigger]} (org.apache.kafka.streams.processor.TopologyBuilder:1371) [2017-05-24 15:30:26,656] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Constructed client metadata {8882e71b-7b0f-4341-8447-8b056415bcb9=ClientMetadata{hostInfo=null, consumers=[reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1-consumer-07122eac-9a4e-4cd0-8821-d9a901c4608c], state=[activeTasks: ([]) standbyTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([0_0]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1]}} from the member subscriptions. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:310) [2017-05-24 15:30:26,657] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Starting to validate internal topics in partition assignor. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:617) [2017-05-24 15:30:26,657] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Completed validating internal topics in partition assignor (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:651) [2017-05-24 15:30:26,657] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Created repartition topics [] from the parsed topology. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:396) [2017-05-24 15:30:26,657] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Starting to validate internal topics in partition assignor. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:617) [2017-05-24 15:30:26,657] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Completed validating internal topics in partition assignor (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:651) [2017-05-24 15:30:26,657] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Created state changelog topics {} from the parsed topology. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:471) [2017-05-24 15:30:26,657] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Assigning tasks [0_0, 0_1, 0_2] to clients {8882e71b-7b0f-4341-8447-8b056415bcb9=[activeTasks: ([]) standbyTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([0_0]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1]} with number of replicas 0 (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:481) [2017-05-24 15:30:26,657] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Assigned tasks to clients as {8882e71b-7b0f-4341-8447-8b056415bcb9=[activeTasks: ([0_0, 0_1, 0_2]) standbyTasks: ([]) assignedTasks: ([0_0, 0_1, 0_2]) prevActiveTasks: ([0_0]) prevAssignedTasks: ([0_0, 0_1, 0_2]) capacity: 1]}. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:487) [2017-05-24 15:30:26,658] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] at state PARTITIONS_REVOKED: new partitions [foo.Trigger-0, foo.Trigger-1, us.Trigger-2, us.Trigger-1, us.Trigger-0, foo.Trigger-2, demo.Trigger-0, demo.Trigger-2, demo.Trigger-1] assigned at the end of consumer rebalance. assigned active tasks: [0_0, 0_1, 0_2] assigned standby tasks: [] current suspended active tasks: [0_0] current suspended standby tasks: [] previous active tasks: [0_0] (org.apache.kafka.streams.processor.internals.StreamThread:154) [2017-05-24 15:30:26,658] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] State transition from PARTITIONS_REVOKED to ASSIGNING_PARTITIONS. (org.apache.kafka.streams.processor.internals.StreamThread:972) [2017-05-24 15:30:26,659] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Adding assigned tasks as active {0_0=[foo.Trigger-0, us.Trigger-0, demo.Trigger-0], 0_1=[foo.Trigger-1, us.Trigger-1, demo.Trigger-1], 0_2=[us.Trigger-2, foo.Trigger-2, demo.Trigger-2]} (org.apache.kafka.streams.processor.internals.StreamThread:1271) [2017-05-24 15:30:26,659] DEBUG task [0_0] Resuming (org.apache.kafka.streams.processor.internals.StreamTask:157) [2017-05-24 15:30:26,659] DEBUG task [0_0] Initializing processor nodes of the topology (org.apache.kafka.streams.processor.internals.StreamTask:316) [2017-05-24 15:30:26,660] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] New active tasks to be created: {0_1=[foo.Trigger-1, us.Trigger-1, demo.Trigger-1], 0_2=[us.Trigger-2, foo.Trigger-2, demo.Trigger-2]} (org.apache.kafka.streams.processor.internals.StreamThread:1302) [2017-05-24 15:30:26,660] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Creating active task 0_1 with assigned partitions [[foo.Trigger-1, us.Trigger-1, demo.Trigger-1]] (org.apache.kafka.streams.processor.internals.StreamThread:1221) [2017-05-24 15:30:26,660] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Acquired state dir lock for task 0_1 (org.apache.kafka.streams.processor.internals.StateDirectory:135) [2017-05-24 15:30:26,660] INFO task [0_1] Created state store manager for task 0_1 with the acquired state dir lock (org.apache.kafka.streams.processor.internals.ProcessorStateManager:122) [2017-05-24 15:30:26,661] DEBUG task [0_1] Initializing (org.apache.kafka.streams.processor.internals.StreamTask:138) [2017-05-24 15:30:26,661] DEBUG task [0_1] Initializing state stores (org.apache.kafka.streams.processor.internals.AbstractTask:194) [2017-05-24 15:30:26,661] DEBUG task [0_1] Updating store offset limits {} (org.apache.kafka.streams.processor.internals.AbstractTask:171) [2017-05-24 15:30:26,661] INFO task [0_1] Register global stores [] (org.apache.kafka.streams.processor.internals.ProcessorStateManager:352) [2017-05-24 15:30:26,662] DEBUG task [0_1] Initializing processor nodes of the topology (org.apache.kafka.streams.processor.internals.StreamTask:316) [2017-05-24 15:30:26,662] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Created active task 0_1 with assigned partitions [foo.Trigger-1, us.Trigger-1, demo.Trigger-1] (org.apache.kafka.streams.processor.internals.StreamThread:1240) [2017-05-24 15:30:26,662] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Creating active task 0_2 with assigned partitions [[us.Trigger-2, foo.Trigger-2, demo.Trigger-2]] (org.apache.kafka.streams.processor.internals.StreamThread:1221) [2017-05-24 15:30:26,663] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Acquired state dir lock for task 0_2 (org.apache.kafka.streams.processor.internals.StateDirectory:135) [2017-05-24 15:30:26,663] INFO task [0_2] Created state store manager for task 0_2 with the acquired state dir lock (org.apache.kafka.streams.processor.internals.ProcessorStateManager:122) [2017-05-24 15:30:26,663] DEBUG task [0_2] Initializing (org.apache.kafka.streams.processor.internals.StreamTask:138) [2017-05-24 15:30:26,663] DEBUG task [0_2] Initializing state stores (org.apache.kafka.streams.processor.internals.AbstractTask:194) [2017-05-24 15:30:26,663] DEBUG task [0_2] Updating store offset limits {} (org.apache.kafka.streams.processor.internals.AbstractTask:171) [2017-05-24 15:30:26,663] INFO task [0_2] Register global stores [] (org.apache.kafka.streams.processor.internals.ProcessorStateManager:352) [2017-05-24 15:30:26,663] DEBUG task [0_2] Initializing processor nodes of the topology (org.apache.kafka.streams.processor.internals.StreamTask:316) [2017-05-24 15:30:26,664] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Created active task 0_2 with assigned partitions [us.Trigger-2, foo.Trigger-2, demo.Trigger-2] (org.apache.kafka.streams.processor.internals.StreamThread:1240) [2017-05-24 15:30:26,664] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Starting restoring state stores from changelog topics [] (org.apache.kafka.streams.processor.internals.StoreChangelogReader:121) [2017-05-24 15:30:26,664] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Took 0 ms to restore all active states (org.apache.kafka.streams.processor.internals.StoreChangelogReader:156) [2017-05-24 15:30:26,664] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Adding assigned standby tasks {0_0=[foo.Trigger-0, us.Trigger-0, demo.Trigger-0], 0_1=[foo.Trigger-1, us.Trigger-1, demo.Trigger-1], 0_2=[us.Trigger-2, foo.Trigger-2, demo.Trigger-2]} (org.apache.kafka.streams.processor.internals.StreamThread:1336) [2017-05-24 15:30:26,664] DEBUG stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] New standby tasks to be created: {} (org.apache.kafka.streams.processor.internals.StreamThread:1355) [2017-05-24 15:30:26,664] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] State transition from ASSIGNING_PARTITIONS to RUNNING. (org.apache.kafka.streams.processor.internals.StreamThread:972) [2017-05-24 15:30:26,664] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] partition assignment took 6 ms. current active tasks: [0_0, 0_1, 0_2] current standby tasks: [] (org.apache.kafka.streams.processor.internals.StreamThread:187) [2017-05-24 15:30:41,203] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Committing all active tasks [0_0, 0_1, 0_2] and standby tasks [] because the commit interval 30000ms has elapsed by 30042ms (org.apache.kafka.streams.processor.internals.StreamThread:767) [2017-05-24 15:30:41,203] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Committing task StreamTask 0_0 (org.apache.kafka.streams.processor.internals.StreamThread:805) [2017-05-24 15:30:41,203] DEBUG task [0_0] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134) [2017-05-24 15:30:41,205] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Committing task StreamTask 0_1 (org.apache.kafka.streams.processor.internals.StreamThread:805) [2017-05-24 15:30:41,206] DEBUG task [0_1] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134) [2017-05-24 15:30:41,207] DEBUG task [0_1] Committing offsets (org.apache.kafka.streams.processor.internals.StreamTask:285) [2017-05-24 15:30:41,208] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Committing task StreamTask 0_2 (org.apache.kafka.streams.processor.internals.StreamThread:805) [2017-05-24 15:30:41,208] DEBUG task [0_2] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134) [2017-05-24 15:30:41,209] DEBUG task [0_2] Committing offsets (org.apache.kafka.streams.processor.internals.StreamTask:285) [2017-05-24 15:31:11,303] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Committing all active tasks [0_0, 0_1, 0_2] and standby tasks [] because the commit interval 30000ms has elapsed by 30099ms (org.apache.kafka.streams.processor.internals.StreamThread:767) [2017-05-24 15:31:11,304] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Committing task StreamTask 0_0 (org.apache.kafka.streams.processor.internals.StreamThread:805) [2017-05-24 15:31:11,304] DEBUG task [0_0] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134) [2017-05-24 15:31:11,305] DEBUG task [0_0] Committing offsets (org.apache.kafka.streams.processor.internals.StreamTask:285) [2017-05-24 15:31:11,306] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Committing task StreamTask 0_1 (org.apache.kafka.streams.processor.internals.StreamThread:805) [2017-05-24 15:31:11,306] DEBUG task [0_1] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134) [2017-05-24 15:31:11,307] DEBUG task [0_1] Committing offsets (org.apache.kafka.streams.processor.internals.StreamTask:285) [2017-05-24 15:31:11,308] INFO stream-thread [reballancing-test-8882e71b-7b0f-4341-8447-8b056415bcb9-StreamThread-1] Committing task StreamTask 0_2 (org.apache.kafka.streams.processor.internals.StreamThread:805) [2017-05-24 15:31:11,309] DEBUG task [0_2] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134) Process finished with exit code 130 (interrupted by signal 2: SIGINT)