[2017-05-24 15:26:14,125] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Creating consumer client (org.apache.kafka.streams.processor.internals.StreamThread:465)
[2017-05-24 15:26:14,190] WARN Error while loading kafka-version.properties :null (org.apache.kafka.common.utils.AppInfoParser:42)
[2017-05-24 15:26:14,191] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Creating restore consumer client (org.apache.kafka.streams.processor.internals.StreamThread:475)
[2017-05-24 15:26:14,202] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] State transition from NOT_RUNNING to RUNNING. (org.apache.kafka.streams.processor.internals.StreamThread:972)
[2017-05-24 15:26:14,495] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Starting (org.apache.kafka.streams.processor.internals.StreamThread:515)
[2017-05-24 15:26:14,510] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-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:14,510] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] State transition from RUNNING to PARTITIONS_REVOKED. (org.apache.kafka.streams.processor.internals.StreamThread:972)
[2017-05-24 15:26:14,510] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] suspendTasksAndState: suspending all active tasks [] and standby tasks [] (org.apache.kafka.streams.processor.internals.StreamThread:1097)
[2017-05-24 15:26:14,511] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Updating suspended tasks to contain active tasks [] (org.apache.kafka.streams.processor.internals.StreamThread:1391)
[2017-05-24 15:26:14,511] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Removing all active tasks [] (org.apache.kafka.streams.processor.internals.StreamThread:1398)
[2017-05-24 15:26:14,511] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Removing all standby tasks [] (org.apache.kafka.streams.processor.internals.StreamThread:1412)
[2017-05-24 15:26:14,511] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-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:14,513] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] found [us.Trigger] topics possibly matching regex (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:258)
[2017-05-24 15:26:14,513] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-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:14,513] DEBUG nodeToSourceTopics {KSTREAM-SOURCE-0000000000=[us.Trigger]} (org.apache.kafka.streams.processor.TopologyBuilder:1371)
[2017-05-24 15:26:17,042] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] at state PARTITIONS_REVOKED: new partitions [us.Trigger-1] assigned at the end of consumer rebalance.
	assigned active tasks: [0_1]
	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:17,046] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] State transition from PARTITIONS_REVOKED to ASSIGNING_PARTITIONS. (org.apache.kafka.streams.processor.internals.StreamThread:972)
[2017-05-24 15:26:17,046] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Adding assigned tasks as active {0_1=[us.Trigger-1]} (org.apache.kafka.streams.processor.internals.StreamThread:1271)
[2017-05-24 15:26:17,046] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] New active tasks to be created: {0_1=[us.Trigger-1]} (org.apache.kafka.streams.processor.internals.StreamThread:1302)
[2017-05-24 15:26:17,046] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-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:17,058] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Creating shared producer client (org.apache.kafka.streams.processor.internals.StreamThread:1254)
[2017-05-24 15:26:17,094] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Acquired state dir lock for task 0_1 (org.apache.kafka.streams.processor.internals.StateDirectory:135)
[2017-05-24 15:26:17,095] 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:17,101] DEBUG task [0_1] Initializing (org.apache.kafka.streams.processor.internals.StreamTask:138)
[2017-05-24 15:26:17,101] DEBUG task [0_1] Initializing state stores (org.apache.kafka.streams.processor.internals.AbstractTask:194)
[2017-05-24 15:26:17,101] DEBUG task [0_1] Updating store offset limits {} (org.apache.kafka.streams.processor.internals.AbstractTask:171)
[2017-05-24 15:26:17,104] INFO task [0_1] Register global stores [] (org.apache.kafka.streams.processor.internals.ProcessorStateManager:352)
[2017-05-24 15:26:17,104] DEBUG task [0_1] Initializing processor nodes of the topology (org.apache.kafka.streams.processor.internals.StreamTask:316)
[2017-05-24 15:26:17,110] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-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:17,110] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Starting restoring state stores from changelog topics [] (org.apache.kafka.streams.processor.internals.StoreChangelogReader:121)
[2017-05-24 15:26:17,110] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Took 0 ms to restore all active states (org.apache.kafka.streams.processor.internals.StoreChangelogReader:156)
[2017-05-24 15:26:17,110] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Adding assigned standby tasks {0_1=[us.Trigger-1]} (org.apache.kafka.streams.processor.internals.StreamThread:1336)
[2017-05-24 15:26:17,110] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] New standby tasks to be created: {} (org.apache.kafka.streams.processor.internals.StreamThread:1355)
[2017-05-24 15:26:17,111] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] State transition from ASSIGNING_PARTITIONS to RUNNING. (org.apache.kafka.streams.processor.internals.StreamThread:972)
[2017-05-24 15:26:17,111] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] partition assignment took 66 ms.
	current active tasks: [0_1]
	current standby tasks: [] (org.apache.kafka.streams.processor.internals.StreamThread:187)
[2017-05-24 15:26:20,121] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] at state RUNNING: partitions [us.Trigger-1] revoked at the beginning of consumer rebalance.
	current assigned active tasks: [0_1]
	current assigned standby tasks: []
 (org.apache.kafka.streams.processor.internals.StreamThread:199)
[2017-05-24 15:26:20,121] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] State transition from RUNNING to PARTITIONS_REVOKED. (org.apache.kafka.streams.processor.internals.StreamThread:972)
[2017-05-24 15:26:20,121] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] suspendTasksAndState: suspending all active tasks [0_1] and standby tasks [] (org.apache.kafka.streams.processor.internals.StreamThread:1097)
[2017-05-24 15:26:20,122] DEBUG task [0_1] Suspending (org.apache.kafka.streams.processor.internals.StreamTask:351)
[2017-05-24 15:26:20,122] DEBUG task [0_1] Closing processor topology (org.apache.kafka.streams.processor.internals.StreamTask:359)
[2017-05-24 15:26:20,128] DEBUG task [0_1] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134)
[2017-05-24 15:26:20,133] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Updating suspended tasks to contain active tasks [0_1] (org.apache.kafka.streams.processor.internals.StreamThread:1391)
[2017-05-24 15:26:20,133] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Removing all active tasks [0_1] (org.apache.kafka.streams.processor.internals.StreamThread:1398)
[2017-05-24 15:26:20,133] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Removing all standby tasks [] (org.apache.kafka.streams.processor.internals.StreamThread:1412)
[2017-05-24 15:26:20,133] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] partition revocation took 12 ms.
	suspended active tasks: [0_1]
	suspended standby tasks: []
	previous active tasks: [0_1]
 (org.apache.kafka.streams.processor.internals.StreamThread:221)
[2017-05-24 15:26:20,134] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] found [us.Trigger] topics possibly matching regex (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:258)
[2017-05-24 15:26:20,134] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-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,134] DEBUG nodeToSourceTopics {KSTREAM-SOURCE-0000000000=[us.Trigger]} (org.apache.kafka.streams.processor.TopologyBuilder:1371)
[2017-05-24 15:26:20,139] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] at state PARTITIONS_REVOKED: new partitions [us.Trigger-1] assigned at the end of consumer rebalance.
	assigned active tasks: [0_1]
	assigned standby tasks: []
	current suspended active tasks: [0_1]
	current suspended standby tasks: []
	previous active tasks: [0_1] (org.apache.kafka.streams.processor.internals.StreamThread:154)
[2017-05-24 15:26:20,140] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-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] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Adding assigned tasks as active {0_1=[us.Trigger-1]} (org.apache.kafka.streams.processor.internals.StreamThread:1271)
[2017-05-24 15:26:20,140] DEBUG task [0_1] Resuming (org.apache.kafka.streams.processor.internals.StreamTask:157)
[2017-05-24 15:26:20,140] DEBUG task [0_1] Initializing processor nodes of the topology (org.apache.kafka.streams.processor.internals.StreamTask:316)
[2017-05-24 15:26:20,156] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] New active tasks to be created: {} (org.apache.kafka.streams.processor.internals.StreamThread:1302)
[2017-05-24 15:26:20,157] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Starting restoring state stores from changelog topics [] (org.apache.kafka.streams.processor.internals.StoreChangelogReader:121)
[2017-05-24 15:26:20,157] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Took 0 ms to restore all active states (org.apache.kafka.streams.processor.internals.StoreChangelogReader:156)
[2017-05-24 15:26:20,157] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Adding assigned standby tasks {0_1=[us.Trigger-1]} (org.apache.kafka.streams.processor.internals.StreamThread:1336)
[2017-05-24 15:26:20,157] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] New standby tasks to be created: {} (org.apache.kafka.streams.processor.internals.StreamThread:1355)
[2017-05-24 15:26:20,157] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] State transition from ASSIGNING_PARTITIONS to RUNNING. (org.apache.kafka.streams.processor.internals.StreamThread:972)
[2017-05-24 15:26:20,157] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] partition assignment took 17 ms.
	current active tasks: [0_1]
	current standby tasks: [] (org.apache.kafka.streams.processor.internals.StreamThread:187)
[2017-05-24 15:26:44,393] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Committing all active tasks [0_1] 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:44,394] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Committing task StreamTask 0_1 (org.apache.kafka.streams.processor.internals.StreamThread:805)
[2017-05-24 15:26:44,394] DEBUG task [0_1] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134)
[2017-05-24 15:26:44,396] DEBUG task [0_1] Committing offsets (org.apache.kafka.streams.processor.internals.StreamTask:285)
[2017-05-24 15:27:14,490] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Committing all active tasks [0_1] and standby tasks [] because the commit interval 30000ms has elapsed by 30100ms (org.apache.kafka.streams.processor.internals.StreamThread:767)
[2017-05-24 15:27:14,490] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Committing task StreamTask 0_1 (org.apache.kafka.streams.processor.internals.StreamThread:805)
[2017-05-24 15:27:14,490] DEBUG task [0_1] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134)
[2017-05-24 15:27:35,098] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] at state RUNNING: partitions [us.Trigger-1] revoked at the beginning of consumer rebalance.
	current assigned active tasks: [0_1]
	current assigned standby tasks: []
 (org.apache.kafka.streams.processor.internals.StreamThread:199)
[2017-05-24 15:27:35,099] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] State transition from RUNNING to PARTITIONS_REVOKED. (org.apache.kafka.streams.processor.internals.StreamThread:972)
[2017-05-24 15:27:35,099] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] suspendTasksAndState: suspending all active tasks [0_1] and standby tasks [] (org.apache.kafka.streams.processor.internals.StreamThread:1097)
[2017-05-24 15:27:35,099] DEBUG task [0_1] Suspending (org.apache.kafka.streams.processor.internals.StreamTask:351)
[2017-05-24 15:27:35,099] DEBUG task [0_1] Closing processor topology (org.apache.kafka.streams.processor.internals.StreamTask:359)
[2017-05-24 15:27:35,102] DEBUG task [0_1] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134)
[2017-05-24 15:27:35,104] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Updating suspended tasks to contain active tasks [0_1] (org.apache.kafka.streams.processor.internals.StreamThread:1391)
[2017-05-24 15:27:35,104] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Removing all active tasks [0_1] (org.apache.kafka.streams.processor.internals.StreamThread:1398)
[2017-05-24 15:27:35,104] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Removing all standby tasks [] (org.apache.kafka.streams.processor.internals.StreamThread:1412)
[2017-05-24 15:27:35,104] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] partition revocation took 5 ms.
	suspended active tasks: [0_1]
	suspended standby tasks: []
	previous active tasks: [0_1]
 (org.apache.kafka.streams.processor.internals.StreamThread:221)
[2017-05-24 15:27:35,104] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] found [us.Trigger, demo.Trigger] topics possibly matching regex (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:258)
[2017-05-24 15:27:35,104] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-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:35,105] DEBUG nodeToSourceTopics {KSTREAM-SOURCE-0000000000=[us.Trigger, demo.Trigger]} (org.apache.kafka.streams.processor.TopologyBuilder:1371)
[2017-05-24 15:27:37,289] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] at state PARTITIONS_REVOKED: new partitions [us.Trigger-1] assigned at the end of consumer rebalance.
	assigned active tasks: [0_1]
	assigned standby tasks: []
	current suspended active tasks: [0_1]
	current suspended standby tasks: []
	previous active tasks: [0_1] (org.apache.kafka.streams.processor.internals.StreamThread:154)
[2017-05-24 15:27:37,290] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-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-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Adding assigned tasks as active {0_1=[us.Trigger-1]} (org.apache.kafka.streams.processor.internals.StreamThread:1271)
[2017-05-24 15:27:37,290] DEBUG task [0_1] Resuming (org.apache.kafka.streams.processor.internals.StreamTask:157)
[2017-05-24 15:27:37,290] DEBUG task [0_1] Initializing processor nodes of the topology (org.apache.kafka.streams.processor.internals.StreamTask:316)
[2017-05-24 15:27:37,294] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] New active tasks to be created: {} (org.apache.kafka.streams.processor.internals.StreamThread:1302)
[2017-05-24 15:27:37,294] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Starting restoring state stores from changelog topics [] (org.apache.kafka.streams.processor.internals.StoreChangelogReader:121)
[2017-05-24 15:27:37,294] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Took 0 ms to restore all active states (org.apache.kafka.streams.processor.internals.StoreChangelogReader:156)
[2017-05-24 15:27:37,295] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Adding assigned standby tasks {0_1=[us.Trigger-1]} (org.apache.kafka.streams.processor.internals.StreamThread:1336)
[2017-05-24 15:27:37,295] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] New standby tasks to be created: {} (org.apache.kafka.streams.processor.internals.StreamThread:1355)
[2017-05-24 15:27:37,295] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] State transition from ASSIGNING_PARTITIONS to RUNNING. (org.apache.kafka.streams.processor.internals.StreamThread:972)
[2017-05-24 15:27:37,295] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] partition assignment took 5 ms.
	current active tasks: [0_1]
	current standby tasks: [] (org.apache.kafka.streams.processor.internals.StreamThread:187)
[2017-05-24 15:27:40,317] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] at state RUNNING: partitions [us.Trigger-1] revoked at the beginning of consumer rebalance.
	current assigned active tasks: [0_1]
	current assigned standby tasks: []
 (org.apache.kafka.streams.processor.internals.StreamThread:199)
[2017-05-24 15:27:40,317] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] State transition from RUNNING to PARTITIONS_REVOKED. (org.apache.kafka.streams.processor.internals.StreamThread:972)
[2017-05-24 15:27:40,317] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] suspendTasksAndState: suspending all active tasks [0_1] and standby tasks [] (org.apache.kafka.streams.processor.internals.StreamThread:1097)
[2017-05-24 15:27:40,317] DEBUG task [0_1] Suspending (org.apache.kafka.streams.processor.internals.StreamTask:351)
[2017-05-24 15:27:40,317] DEBUG task [0_1] Closing processor topology (org.apache.kafka.streams.processor.internals.StreamTask:359)
[2017-05-24 15:27:40,319] DEBUG task [0_1] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134)
[2017-05-24 15:27:40,320] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Updating suspended tasks to contain active tasks [0_1] (org.apache.kafka.streams.processor.internals.StreamThread:1391)
[2017-05-24 15:27:40,320] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Removing all active tasks [0_1] (org.apache.kafka.streams.processor.internals.StreamThread:1398)
[2017-05-24 15:27:40,320] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Removing all standby tasks [] (org.apache.kafka.streams.processor.internals.StreamThread:1412)
[2017-05-24 15:27:40,320] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] partition revocation took 3 ms.
	suspended active tasks: [0_1]
	suspended standby tasks: []
	previous active tasks: [0_1]
 (org.apache.kafka.streams.processor.internals.StreamThread:221)
[2017-05-24 15:27:40,321] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] found [us.Trigger, demo.Trigger] topics possibly matching regex (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:258)
[2017-05-24 15:27:40,321] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-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:40,321] DEBUG nodeToSourceTopics {KSTREAM-SOURCE-0000000000=[us.Trigger, demo.Trigger]} (org.apache.kafka.streams.processor.TopologyBuilder:1371)
[2017-05-24 15:27:40,325] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] at state PARTITIONS_REVOKED: new partitions [us.Trigger-1, demo.Trigger-1] assigned at the end of consumer rebalance.
	assigned active tasks: [0_1]
	assigned standby tasks: []
	current suspended active tasks: [0_1]
	current suspended standby tasks: []
	previous active tasks: [0_1] (org.apache.kafka.streams.processor.internals.StreamThread:154)
[2017-05-24 15:27:40,326] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-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-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Closing suspended non-assigned active task 0_1 (org.apache.kafka.streams.processor.internals.StreamThread:1189)
[2017-05-24 15:27:40,326] DEBUG task [0_1] Closing (org.apache.kafka.streams.processor.internals.StreamTask:398)
[2017-05-24 15:27:40,326] DEBUG task [0_1] Suspending (org.apache.kafka.streams.processor.internals.StreamTask:351)
[2017-05-24 15:27:40,326] DEBUG task [0_1] Closing processor topology (org.apache.kafka.streams.processor.internals.StreamTask:359)
[2017-05-24 15:27:40,326] DEBUG task [0_1] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134)
[2017-05-24 15:27:40,329] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Released state dir lock for task 0_1 (org.apache.kafka.streams.processor.internals.StateDirectory:191)
[2017-05-24 15:27:40,330] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Adding assigned tasks as active {0_1=[us.Trigger-1, demo.Trigger-1]} (org.apache.kafka.streams.processor.internals.StreamThread:1271)
[2017-05-24 15:27:40,330] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] New active tasks to be created: {0_1=[us.Trigger-1, demo.Trigger-1]} (org.apache.kafka.streams.processor.internals.StreamThread:1302)
[2017-05-24 15:27:40,330] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Creating active task 0_1 with assigned partitions [[us.Trigger-1, demo.Trigger-1]] (org.apache.kafka.streams.processor.internals.StreamThread:1221)
[2017-05-24 15:27:40,331] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Acquired state dir lock for task 0_1 (org.apache.kafka.streams.processor.internals.StateDirectory:135)
[2017-05-24 15:27:40,331] 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:27:40,331] DEBUG task [0_1] Initializing (org.apache.kafka.streams.processor.internals.StreamTask:138)
[2017-05-24 15:27:40,331] DEBUG task [0_1] Initializing state stores (org.apache.kafka.streams.processor.internals.AbstractTask:194)
[2017-05-24 15:27:40,331] DEBUG task [0_1] Updating store offset limits {} (org.apache.kafka.streams.processor.internals.AbstractTask:171)
[2017-05-24 15:27:40,332] INFO task [0_1] Register global stores [] (org.apache.kafka.streams.processor.internals.ProcessorStateManager:352)
[2017-05-24 15:27:40,332] DEBUG task [0_1] Initializing processor nodes of the topology (org.apache.kafka.streams.processor.internals.StreamTask:316)
[2017-05-24 15:27:40,334] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Created active task 0_1 with assigned partitions [us.Trigger-1, demo.Trigger-1] (org.apache.kafka.streams.processor.internals.StreamThread:1240)
[2017-05-24 15:27:40,335] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Starting restoring state stores from changelog topics [] (org.apache.kafka.streams.processor.internals.StoreChangelogReader:121)
[2017-05-24 15:27:40,335] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Took 1 ms to restore all active states (org.apache.kafka.streams.processor.internals.StoreChangelogReader:156)
[2017-05-24 15:27:40,335] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Adding assigned standby tasks {0_1=[us.Trigger-1, demo.Trigger-1]} (org.apache.kafka.streams.processor.internals.StreamThread:1336)
[2017-05-24 15:27:40,335] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] New standby tasks to be created: {} (org.apache.kafka.streams.processor.internals.StreamThread:1355)
[2017-05-24 15:27:40,335] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] State transition from ASSIGNING_PARTITIONS to RUNNING. (org.apache.kafka.streams.processor.internals.StreamThread:972)
[2017-05-24 15:27:40,335] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] partition assignment took 9 ms.
	current active tasks: [0_1]
	current standby tasks: [] (org.apache.kafka.streams.processor.internals.StreamThread:187)
[2017-05-24 15:27:44,520] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Committing all active tasks [0_1] and standby tasks [] because the commit interval 30000ms has elapsed by 30027ms (org.apache.kafka.streams.processor.internals.StreamThread:767)
[2017-05-24 15:27:44,520] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Committing task StreamTask 0_1 (org.apache.kafka.streams.processor.internals.StreamThread:805)
[2017-05-24 15:27:44,520] DEBUG task [0_1] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134)
[2017-05-24 15:27:44,522] DEBUG task [0_1] Committing offsets (org.apache.kafka.streams.processor.internals.StreamTask:285)
[2017-05-24 15:28:14,544] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Committing all active tasks [0_1] and standby tasks [] because the commit interval 30000ms has elapsed by 30024ms (org.apache.kafka.streams.processor.internals.StreamThread:767)
[2017-05-24 15:28:14,544] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Committing task StreamTask 0_1 (org.apache.kafka.streams.processor.internals.StreamThread:805)
[2017-05-24 15:28:14,544] DEBUG task [0_1] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134)
[2017-05-24 15:28:14,546] DEBUG task [0_1] Committing offsets (org.apache.kafka.streams.processor.internals.StreamTask:285)
[2017-05-24 15:28:44,637] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Committing all active tasks [0_1] and standby tasks [] because the commit interval 30000ms has elapsed by 30096ms (org.apache.kafka.streams.processor.internals.StreamThread:767)
[2017-05-24 15:28:44,637] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Committing task StreamTask 0_1 (org.apache.kafka.streams.processor.internals.StreamThread:805)
[2017-05-24 15:28:44,637] DEBUG task [0_1] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134)
[2017-05-24 15:28:44,639] DEBUG task [0_1] Committing offsets (org.apache.kafka.streams.processor.internals.StreamTask:285)
[2017-05-24 15:29:14,713] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Committing all active tasks [0_1] and standby tasks [] because the commit interval 30000ms has elapsed by 30074ms (org.apache.kafka.streams.processor.internals.StreamThread:767)
[2017-05-24 15:29:14,714] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Committing task StreamTask 0_1 (org.apache.kafka.streams.processor.internals.StreamThread:805)
[2017-05-24 15:29:14,714] DEBUG task [0_1] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134)
[2017-05-24 15:29:44,783] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Committing all active tasks [0_1] and standby tasks [] because the commit interval 30000ms has elapsed by 30072ms (org.apache.kafka.streams.processor.internals.StreamThread:767)
[2017-05-24 15:29:44,784] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Committing task StreamTask 0_1 (org.apache.kafka.streams.processor.internals.StreamThread:805)
[2017-05-24 15:29:44,784] DEBUG task [0_1] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134)
[2017-05-24 15:30:14,361] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] at state RUNNING: partitions [us.Trigger-1, demo.Trigger-1] revoked at the beginning of consumer rebalance.
	current assigned active tasks: [0_1]
	current assigned standby tasks: []
 (org.apache.kafka.streams.processor.internals.StreamThread:199)
[2017-05-24 15:30:14,361] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] State transition from RUNNING to PARTITIONS_REVOKED. (org.apache.kafka.streams.processor.internals.StreamThread:972)
[2017-05-24 15:30:14,361] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] suspendTasksAndState: suspending all active tasks [0_1] and standby tasks [] (org.apache.kafka.streams.processor.internals.StreamThread:1097)
[2017-05-24 15:30:14,361] DEBUG task [0_1] Suspending (org.apache.kafka.streams.processor.internals.StreamTask:351)
[2017-05-24 15:30:14,362] DEBUG task [0_1] Closing processor topology (org.apache.kafka.streams.processor.internals.StreamTask:359)
[2017-05-24 15:30:14,363] DEBUG task [0_1] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134)
[2017-05-24 15:30:14,365] DEBUG task [0_1] Committing offsets (org.apache.kafka.streams.processor.internals.StreamTask:285)
[2017-05-24 15:30:14,366] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Updating suspended tasks to contain active tasks [0_1] (org.apache.kafka.streams.processor.internals.StreamThread:1391)
[2017-05-24 15:30:14,366] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Removing all active tasks [0_1] (org.apache.kafka.streams.processor.internals.StreamThread:1398)
[2017-05-24 15:30:14,366] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Removing all standby tasks [] (org.apache.kafka.streams.processor.internals.StreamThread:1412)
[2017-05-24 15:30:14,367] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] partition revocation took 6 ms.
	suspended active tasks: [0_1]
	suspended standby tasks: []
	previous active tasks: [0_1]
 (org.apache.kafka.streams.processor.internals.StreamThread:221)
[2017-05-24 15:30:14,367] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] found [us.Trigger, demo.Trigger] topics possibly matching regex (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:258)
[2017-05-24 15:30:14,367] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-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:30:14,367] DEBUG nodeToSourceTopics {KSTREAM-SOURCE-0000000000=[us.Trigger, demo.Trigger]} (org.apache.kafka.streams.processor.TopologyBuilder:1371)
[2017-05-24 15:30:14,474] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] at state PARTITIONS_REVOKED: new partitions [foo.Trigger-1, us.Trigger-1, demo.Trigger-1] assigned at the end of consumer rebalance.
	assigned active tasks: [0_1]
	assigned standby tasks: []
	current suspended active tasks: [0_1]
	current suspended standby tasks: []
	previous active tasks: [0_1] (org.apache.kafka.streams.processor.internals.StreamThread:154)
[2017-05-24 15:30:14,474] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] State transition from PARTITIONS_REVOKED to ASSIGNING_PARTITIONS. (org.apache.kafka.streams.processor.internals.StreamThread:972)
[2017-05-24 15:30:14,474] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Closing suspended non-assigned active task 0_1 (org.apache.kafka.streams.processor.internals.StreamThread:1189)
[2017-05-24 15:30:14,475] DEBUG task [0_1] Closing (org.apache.kafka.streams.processor.internals.StreamTask:398)
[2017-05-24 15:30:14,475] DEBUG task [0_1] Suspending (org.apache.kafka.streams.processor.internals.StreamTask:351)
[2017-05-24 15:30:14,475] DEBUG task [0_1] Closing processor topology (org.apache.kafka.streams.processor.internals.StreamTask:359)
[2017-05-24 15:30:14,475] DEBUG task [0_1] Flushing producer (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:134)
[2017-05-24 15:30:14,476] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Released state dir lock for task 0_1 (org.apache.kafka.streams.processor.internals.StateDirectory:191)
[2017-05-24 15:30:14,476] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Adding assigned tasks as active {0_1=[foo.Trigger-1, us.Trigger-1, demo.Trigger-1]} (org.apache.kafka.streams.processor.internals.StreamThread:1271)
[2017-05-24 15:30:14,476] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] New active tasks to be created: {0_1=[foo.Trigger-1, us.Trigger-1, demo.Trigger-1]} (org.apache.kafka.streams.processor.internals.StreamThread:1302)
[2017-05-24 15:30:14,477] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-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:14,477] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Acquired state dir lock for task 0_1 (org.apache.kafka.streams.processor.internals.StateDirectory:135)
[2017-05-24 15:30:14,477] 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:14,478] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-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:14,478] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] partition assignment took 4 ms.
	current active tasks: []
	current standby tasks: [] (org.apache.kafka.streams.processor.internals.StreamThread:187)
[2017-05-24 15:30:14,479] ERROR User provided listener org.apache.kafka.streams.processor.internals.StreamThread$RebalanceListener for group reballancing-test failed on partition assignment (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:269)
java.lang.NullPointerException
	at org.apache.kafka.streams.processor.internals.StreamTask.<init>(StreamTask.java:122)
	at org.apache.kafka.streams.processor.internals.StreamThread.createStreamTask(StreamThread.java:1238)
	at org.apache.kafka.streams.processor.internals.StreamThread$TaskCreator.createTask(StreamThread.java:286)
	at org.apache.kafka.streams.processor.internals.StreamThread$AbstractTaskCreator.retryWithBackoff(StreamThread.java:247)
	at org.apache.kafka.streams.processor.internals.StreamThread.addStreamTasks(StreamThread.java:1304)
	at org.apache.kafka.streams.processor.internals.StreamThread.access$1100(StreamThread.java:72)
	at org.apache.kafka.streams.processor.internals.StreamThread$RebalanceListener.onPartitionsAssigned(StreamThread.java:177)
	at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.onJoinComplete(ConsumerCoordinator.java:265)
	at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:363)
	at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:310)
	at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:296)
	at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1046)
	at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1011)
	at org.apache.kafka.streams.processor.internals.StreamThread.pollRequests(StreamThread.java:574)
	at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:545)
	at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:519)
[2017-05-24 15:30:14,482] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Shutting down (org.apache.kafka.streams.processor.internals.StreamThread:1032)
[2017-05-24 15:30:14,482] DEBUG stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] shutdownTasksAndState: shutting downactive tasks [], standby tasks [], suspended tasks [], and suspended standby tasks [] (org.apache.kafka.streams.processor.internals.StreamThread:1071)
[2017-05-24 15:30:14,486] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Removing all active tasks [] (org.apache.kafka.streams.processor.internals.StreamThread:1398)
[2017-05-24 15:30:14,486] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Removing all standby tasks [] (org.apache.kafka.streams.processor.internals.StreamThread:1412)
[2017-05-24 15:30:14,486] INFO stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Stream thread shutdown complete (org.apache.kafka.streams.processor.internals.StreamThread:1064)
[2017-05-24 15:30:14,486] WARN stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Unexpected state transition from ASSIGNING_PARTITIONS to NOT_RUNNING. (org.apache.kafka.streams.processor.internals.StreamThread:970)
found exception stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Failed to rebalance.
org.apache.kafka.streams.errors.StreamsException: stream-thread [reballancing-test-df1e3cfa-5620-4a81-89bf-88ed14115321-StreamThread-1] Failed to rebalance.
	at org.apache.kafka.streams.processor.internals.StreamThread.pollRequests(StreamThread.java:581)
	at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:545)
	at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:519)
Caused by: java.lang.NullPointerException
	at org.apache.kafka.streams.processor.internals.StreamTask.<init>(StreamTask.java:122)
	at org.apache.kafka.streams.processor.internals.StreamThread.createStreamTask(StreamThread.java:1238)
	at org.apache.kafka.streams.processor.internals.StreamThread$TaskCreator.createTask(StreamThread.java:286)
	at org.apache.kafka.streams.processor.internals.StreamThread$AbstractTaskCreator.retryWithBackoff(StreamThread.java:247)
	at org.apache.kafka.streams.processor.internals.StreamThread.addStreamTasks(StreamThread.java:1304)
	at org.apache.kafka.streams.processor.internals.StreamThread.access$1100(StreamThread.java:72)
	at org.apache.kafka.streams.processor.internals.StreamThread$RebalanceListener.onPartitionsAssigned(StreamThread.java:177)
	at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.onJoinComplete(ConsumerCoordinator.java:265)
	at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:363)
	at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:310)
	at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:296)
	at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1046)
	at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1011)
	at org.apache.kafka.streams.processor.internals.StreamThread.pollRequests(StreamThread.java:574)
	... 2 more

Process finished with exit code 0