[2020-03-20T12:40:16-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_gclog) 7898.416: [GC (Allocation Failure)  244839K->124039K(397824K), 0.0020697 secs]
[2020-03-20T12:40:16-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_gclog) 7898.929: [GC (Allocation Failure)  242823K->124007K(393216K), 0.0022126 secs]
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,972] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-1] [Consumer clientId=stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-1-consumer, groupId=stream-soak-test] Successfully joined group with generation 655 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,972] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-3] [Consumer clientId=stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-3-consumer, groupId=stream-soak-test] Successfully joined group with generation 655 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,972] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-1] [Consumer clientId=stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-1-consumer, groupId=stream-soak-test] Updating assignment with
	Assigned partitions:                       []
	Current owned partitions:                  [logs.json.zookeeper-0, logs.operator-0, logs.kubernetes-0, logs.syslog-0, logs.json.kafka-0]
	Added partitions (assigned - owned):       []
	Revoked partitions (owned - assigned):     [logs.json.zookeeper-0, logs.operator-0, logs.kubernetes-0, logs.syslog-0, logs.json.kafka-0]
 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,972] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-3] [Consumer clientId=stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-3-consumer, groupId=stream-soak-test] Updating assignment with
	Assigned partitions:                       []
	Current owned partitions:                  []
	Added partitions (assigned - owned):       []
	Revoked partitions (owned - assigned):     []
 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,972] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-3] stream-thread [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-3] Handle new assignment with:
	New active tasks: []
	New standby tasks: []
	Existing active tasks: []
	Existing standby tasks: [] (org.apache.kafka.streams.processor.internals.TaskManager)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,972] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] [Consumer clientId=stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2-consumer, groupId=stream-soak-test] Successfully joined group with generation 655 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,972] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-3] [Consumer clientId=stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-3-consumer, groupId=stream-soak-test] Adding newly assigned partitions:  (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,972] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-3] stream-thread [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-3] State transition from RUNNING to PARTITIONS_ASSIGNED (org.apache.kafka.streams.processor.internals.StreamThread)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,972] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-3] stream-client [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a] State transition from RUNNING to REBALANCING (org.apache.kafka.streams.KafkaStreams)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,972] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] [Consumer clientId=stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2-consumer, groupId=stream-soak-test] Updating assignment with
	Assigned partitions:                       []
	Current owned partitions:                  [logs.json.kafka-2, logs.json.zookeeper-2, logs.kubernetes-2, logs.operator-2, k8sName-id-repartition-1, logs.syslog-2]
	Added partitions (assigned - owned):       []
	Revoked partitions (owned - assigned):     [logs.json.kafka-2, logs.json.zookeeper-2, logs.kubernetes-2, logs.operator-2, k8sName-id-repartition-1, logs.syslog-2]
 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,972] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] [Consumer clientId=stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2-consumer, groupId=stream-soak-test] Revoke previously assigned partitions logs.json.kafka-2, logs.json.zookeeper-2, logs.kubernetes-2, logs.operator-2, k8sName-id-repartition-1, logs.syslog-2 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,972] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] stream-thread [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] State transition from RUNNING to PARTITIONS_REVOKED (org.apache.kafka.streams.processor.internals.StreamThread)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,972] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-1] [Consumer clientId=stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-1-consumer, groupId=stream-soak-test] Revoke previously assigned partitions logs.json.zookeeper-0, logs.operator-0, logs.kubernetes-0, logs.syslog-0, logs.json.kafka-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,973] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-1] stream-thread [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-1] State transition from RUNNING to PARTITIONS_REVOKED (org.apache.kafka.streams.processor.internals.StreamThread)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,974] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-1] stream-thread [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-1] task [0_0] Prepare suspending running (org.apache.kafka.streams.processor.internals.StreamTask)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,974] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] stream-thread [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] task [0_2] Prepare suspending running (org.apache.kafka.streams.processor.internals.StreamTask)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,974] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] stream-thread [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] task [3_1] Prepare suspending running (org.apache.kafka.streams.processor.internals.StreamTask)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,982] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-1] stream-thread [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-1] task [0_0] Suspended running (org.apache.kafka.streams.processor.internals.StreamTask)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,982] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-1] stream-thread [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-1] partition revocation took 9 ms. (org.apache.kafka.streams.processor.internals.StreamThread)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,982] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-1] stream-thread [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-1] Handle new assignment with:
	New active tasks: []
	New standby tasks: []
	Existing active tasks: [0_0]
	Existing standby tasks: [] (org.apache.kafka.streams.processor.internals.TaskManager)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,982] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-1] stream-thread [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-1] task [0_0] Prepared clean close (org.apache.kafka.streams.processor.internals.StreamTask)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,982] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-1] stream-thread [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-1] task [0_0] Closed clean (org.apache.kafka.streams.processor.internals.StreamTask)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,982] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-1] [Producer clientId=stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-1-0_0-producer, transactionalId=stream-soak-test-0_0] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,983] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-1] [Consumer clientId=stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-1-consumer, groupId=stream-soak-test] Adding newly assigned partitions:  (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,983] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-1] stream-thread [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-1] State transition from PARTITIONS_REVOKED to PARTITIONS_ASSIGNED (org.apache.kafka.streams.processor.internals.StreamThread)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,983] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-1] [Consumer clientId=stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-1-consumer, groupId=stream-soak-test] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,994] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] stream-thread [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] task [0_2] Suspended running (org.apache.kafka.streams.processor.internals.StreamTask)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,994] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] stream-thread [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] task [3_1] Suspended running (org.apache.kafka.streams.processor.internals.StreamTask)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,994] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] stream-thread [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] partition revocation took 22 ms. (org.apache.kafka.streams.processor.internals.StreamThread)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,994] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] stream-thread [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] Handle new assignment with:
	New active tasks: []
	New standby tasks: []
	Existing active tasks: [0_2, 3_1]
	Existing standby tasks: [] (org.apache.kafka.streams.processor.internals.TaskManager)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,994] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] stream-thread [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] task [0_2] Prepared clean close (org.apache.kafka.streams.processor.internals.StreamTask)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,994] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] [Consumer clientId=stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2-restore-consumer, groupId=null] Unsubscribed all topics or patterns and assigned partitions (org.apache.kafka.clients.consumer.KafkaConsumer)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,995] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] stream-thread [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] task [3_1] Prepared clean close (org.apache.kafka.streams.processor.internals.StreamTask)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,995] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] stream-thread [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] task [0_2] Closed clean (org.apache.kafka.streams.processor.internals.StreamTask)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,995] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] [Producer clientId=stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2-0_2-producer, transactionalId=stream-soak-test-0_2] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,997] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] stream-thread [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] task [3_1] Closed clean (org.apache.kafka.streams.processor.internals.StreamTask)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,997] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] [Producer clientId=stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2-3_1-producer, transactionalId=stream-soak-test-3_1] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,998] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] [Consumer clientId=stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2-consumer, groupId=stream-soak-test] Adding newly assigned partitions:  (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,998] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] stream-thread [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] State transition from PARTITIONS_REVOKED to PARTITIONS_ASSIGNED (org.apache.kafka.streams.processor.internals.StreamThread)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:16,998] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] [Consumer clientId=stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2-consumer, groupId=stream-soak-test] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:17,063] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-1] stream-thread [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-1] State transition from PARTITIONS_ASSIGNED to RUNNING (org.apache.kafka.streams.processor.internals.StreamThread)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:17,065] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-3] stream-thread [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-3] State transition from PARTITIONS_ASSIGNED to RUNNING (org.apache.kafka.streams.processor.internals.StreamThread)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:17,077] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] stream-thread [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] State transition from PARTITIONS_ASSIGNED to RUNNING (org.apache.kafka.streams.processor.internals.StreamThread)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:17,077] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] stream-client [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a] State transition from REBALANCING to RUNNING (org.apache.kafka.streams.KafkaStreams)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0c608c897870c5558_streamslog) [2020-03-20 17:40:17,077] INFO [stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2] metadata details [ThreadMetadata{threadName=stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-1, threadState=RUNNING, activeTasks=[], standbyTasks=[], consumerClientId=stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-1-consumer, restoreConsumerClientId=stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-1-restore-consumer, producerClientIds=[], adminClientId=stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-admin}, ThreadMetadata{threadName=stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-3, threadState=RUNNING, activeTasks=[], standbyTasks=[], consumerClientId=stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-3-consumer, restoreConsumerClientId=stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-3-restore-consumer, producerClientIds=[], adminClientId=stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-admin}, ThreadMetadata{threadName=stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2, threadState=RUNNING, activeTasks=[], standbyTasks=[], consumerClientId=stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2-consumer, restoreConsumerClientId=stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2-restore-consumer, producerClientIds=[], adminClientId=stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-admin}] (org.apache.kafka.streams.StreamsSoakTest)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:16,969] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-3] stream-thread [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-3-consumer] Assigned tasks to clients as 
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) 262ab0fb-438e-4810-9ef8-c008eaaebcc1=[activeTasks: ([1_0, 0_1, 2_0, 3_0]) standbyTasks: ([]) assignedTasks: ([1_0, 0_1, 2_0, 3_0]) prevActiveTasks: ([1_0, 2_0, 3_0, 2_2, 3_2]) prevStandbyTasks: ([1_2, 3_1]) prevAssignedTasks: ([1_0, 2_0, 1_2, 3_0, 3_1, 2_2, 3_2]) prevOwnedPartitionsByConsumerId: ([node-name-repartition-0, network-id-repartition-2, network-id-repartition-0, windowed-node-counts-0, k8sName-id-repartition-0, k8sName-id-repartition-2]) capacity: 3]
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) 2d943a10-c98a-4557-a010-dfba3798266a=[activeTasks: ([1_1, 0_2, 3_1, 3_2]) standbyTasks: ([]) assignedTasks: ([1_1, 0_2, 3_1, 3_2]) prevActiveTasks: ([3_1]) prevStandbyTasks: ([1_1, 2_0, 3_0, 3_2]) prevAssignedTasks: ([1_1, 2_0, 3_0, 3_1, 3_2]) prevOwnedPartitionsByConsumerId: ([logs.json.zookeeper-0, logs.json.kafka-2, logs.operator-0, logs.json.zookeeper-2, logs.kubernetes-2, logs.kubernetes-0, logs.operator-2, logs.syslog-0, logs.syslog-2, k8sName-id-repartition-1, logs.json.kafka-0]) capacity: 3]
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) f7392d33-55d7-484f-8b72-578e22fead96=[activeTasks: ([0_0, 2_1, 1_2, 2_2]) standbyTasks: ([]) assignedTasks: ([0_0, 2_1, 1_2, 2_2]) prevActiveTasks: ([2_1]) prevStandbyTasks: ([1_1, 1_2]) prevAssignedTasks: ([1_1, 1_2, 2_1]) prevOwnedPartitionsByConsumerId: ([logs.json.kafka-1, logs.json.zookeeper-1, node-name-repartition-1, logs.kubernetes-1, network-id-repartition-1, logs.operator-1, windowed-node-counts-1, windowed-node-counts-2, logs.syslog-1, node-name-repartition-2]) capacity: 3]. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:16,970] WARN [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-3] [Consumer clientId=stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-3-consumer, groupId=stream-soak-test] The following subscribed topics are not assigned to any members: [logs.json.kafka, logs.json.zookeeper, logs.kubernetes, logs.operator, logs.syslog, k8sName-id-repartition]  (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:16,970] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-3] [Consumer clientId=stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-3-consumer, groupId=stream-soak-test] Finished assignment for group at generation 655: {stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-1-consumer-34c2198b-5bdd-470b-ae50-30a39873edab=Assignment(partitions=[], userDataSize=32), stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-2-consumer-7e05013d-a49e-4e2a-83ea-f2f00c4b3aaf=Assignment(partitions=[node-name-repartition-2, windowed-node-counts-2], userDataSize=48), stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-2-consumer-74087bef-9084-4b6b-b669-32f2ea6c4801=Assignment(partitions=[], userDataSize=32), stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-3-consumer-d80a6853-7e26-481d-9f7e-f4cbbb6e03f2=Assignment(partitions=[], userDataSize=32), stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1-consumer-ad3d0a9c-9382-4e31-b676-58d21239a9fa=Assignment(partitions=[], userDataSize=32), stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-3-consumer-5dd0ecd1-3e80-44d0-b717-cb509911afd5=Assignment(partitions=[network-id-repartition-1], userDataSize=40), stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-1-consumer-f5ed8f77-6125-403f-afc5-0cf849d58e62=Assignment(partitions=[], userDataSize=32), stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2-consumer-5f13e2e5-c8e8-423e-a663-7993dc5341f0=Assignment(partitions=[], userDataSize=32), stream-soak-test-2d943a10-c98a-4557-a010-dfba3798266a-StreamThread-3-consumer-fe76c1da-abd1-4a9f-a6d4-31bdb107f038=Assignment(partitions=[], userDataSize=32)} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:16,975] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1] [Consumer clientId=stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1-consumer, groupId=stream-soak-test] Successfully joined group with generation 655 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:16,975] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1] [Consumer clientId=stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1-consumer, groupId=stream-soak-test] Updating assignment with
	Assigned partitions:                       []
	Current owned partitions:                  [network-id-repartition-0]
	Added partitions (assigned - owned):       []
	Revoked partitions (owned - assigned):     [network-id-repartition-0]
 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:16,975] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1] [Consumer clientId=stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1-consumer, groupId=stream-soak-test] Revoke previously assigned partitions network-id-repartition-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:16,975] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1] stream-thread [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1] State transition from RUNNING to PARTITIONS_REVOKED (org.apache.kafka.streams.processor.internals.StreamThread)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:16,975] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1] stream-client [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1] State transition from RUNNING to REBALANCING (org.apache.kafka.streams.KafkaStreams)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:16,977] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] [Consumer clientId=stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2-consumer, groupId=stream-soak-test] Successfully joined group with generation 655 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:16,977] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] [Consumer clientId=stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2-consumer, groupId=stream-soak-test] Updating assignment with
	Assigned partitions:                       []
	Current owned partitions:                  [network-id-repartition-2, k8sName-id-repartition-0]
	Added partitions (assigned - owned):       []
	Revoked partitions (owned - assigned):     [network-id-repartition-2, k8sName-id-repartition-0]
 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:16,977] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] [Consumer clientId=stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2-consumer, groupId=stream-soak-test] Revoke previously assigned partitions network-id-repartition-2, k8sName-id-repartition-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:16,977] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] stream-thread [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] State transition from RUNNING to PARTITIONS_REVOKED (org.apache.kafka.streams.processor.internals.StreamThread)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:16,977] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] stream-thread [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] task [2_2] Prepare suspending running (org.apache.kafka.streams.processor.internals.StreamTask)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:16,984] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] stream-thread [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] task [3_0] Prepare suspending running (org.apache.kafka.streams.processor.internals.StreamTask)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:16,985] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1] stream-thread [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1] task [2_0] Prepare suspending running (org.apache.kafka.streams.processor.internals.StreamTask)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:16,996] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1] stream-thread [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1] task [2_0] Suspended running (org.apache.kafka.streams.processor.internals.StreamTask)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:16,996] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1] stream-thread [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1] partition revocation took 21 ms. (org.apache.kafka.streams.processor.internals.StreamThread)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:16,996] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1] stream-thread [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1] Handle new assignment with:
	New active tasks: []
	New standby tasks: []
	Existing active tasks: [2_0]
	Existing standby tasks: [] (org.apache.kafka.streams.processor.internals.TaskManager)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:16,996] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1] [Consumer clientId=stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1-restore-consumer, groupId=null] Unsubscribed all topics or patterns and assigned partitions (org.apache.kafka.clients.consumer.KafkaConsumer)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:16,996] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1] stream-thread [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1] task [2_0] Prepared clean close (org.apache.kafka.streams.processor.internals.StreamTask)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:17,001] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1] stream-thread [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1] task [2_0] Closed clean (org.apache.kafka.streams.processor.internals.StreamTask)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:17,001] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1] [Producer clientId=stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1-2_0-producer, transactionalId=stream-soak-test-2_0] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:17,004] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] stream-thread [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] task [2_2] Suspended running (org.apache.kafka.streams.processor.internals.StreamTask)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:17,005] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1] [Consumer clientId=stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1-consumer, groupId=stream-soak-test] Adding newly assigned partitions:  (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:17,005] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] stream-thread [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] task [3_0] Suspended running (org.apache.kafka.streams.processor.internals.StreamTask)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:17,005] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] stream-thread [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] partition revocation took 28 ms. (org.apache.kafka.streams.processor.internals.StreamThread)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:17,005] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] stream-thread [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] Handle new assignment with:
	New active tasks: []
	New standby tasks: []
	Existing active tasks: [3_0, 2_2]
	Existing standby tasks: [] (org.apache.kafka.streams.processor.internals.TaskManager)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:17,005] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] [Consumer clientId=stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2-restore-consumer, groupId=null] Subscribed to partition(s): stream-soak-test-KSTREAM-AGGREGATE-STATE-STORE-0000000049-changelog-0 (org.apache.kafka.clients.consumer.KafkaConsumer)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:17,005] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] stream-thread [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] task [2_2] Prepared clean close (org.apache.kafka.streams.processor.internals.StreamTask)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:17,006] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] [Consumer clientId=stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2-restore-consumer, groupId=null] Unsubscribed all topics or patterns and assigned partitions (org.apache.kafka.clients.consumer.KafkaConsumer)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:17,006] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] stream-thread [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] task [3_0] Prepared clean close (org.apache.kafka.streams.processor.internals.StreamTask)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:17,008] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] stream-thread [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] task [3_0] Closed clean (org.apache.kafka.streams.processor.internals.StreamTask)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:17,008] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] [Producer clientId=stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2-3_0-producer, transactionalId=stream-soak-test-3_0] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:17,012] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1] stream-thread [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1] State transition from PARTITIONS_REVOKED to PARTITIONS_ASSIGNED (org.apache.kafka.streams.processor.internals.StreamThread)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:17,012] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1] [Consumer clientId=stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1-consumer, groupId=stream-soak-test] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:17,032] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] stream-thread [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] task [2_2] Closed clean (org.apache.kafka.streams.processor.internals.StreamTask)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:17,032] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] [Producer clientId=stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2-2_2-producer, transactionalId=stream-soak-test-2_2] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:17,037] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] [Consumer clientId=stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2-consumer, groupId=stream-soak-test] Adding newly assigned partitions:  (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:17,037] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] stream-thread [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] State transition from PARTITIONS_REVOKED to PARTITIONS_ASSIGNED (org.apache.kafka.streams.processor.internals.StreamThread)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:17,037] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] [Consumer clientId=stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2-consumer, groupId=stream-soak-test] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:17,049] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1] stream-thread [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1] State transition from PARTITIONS_ASSIGNED to RUNNING (org.apache.kafka.streams.processor.internals.StreamThread)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:17,054] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] stream-thread [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] State transition from PARTITIONS_ASSIGNED to RUNNING (org.apache.kafka.streams.processor.internals.StreamThread)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:17,054] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] stream-client [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1] State transition from REBALANCING to RUNNING (org.apache.kafka.streams.KafkaStreams)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-0b6648e2d2c195a42_streamslog) [2020-03-20 17:40:17,054] INFO [stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2] metadata details [ThreadMetadata{threadName=stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2, threadState=RUNNING, activeTasks=[], standbyTasks=[], consumerClientId=stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2-consumer, restoreConsumerClientId=stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-2-restore-consumer, producerClientIds=[], adminClientId=stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-admin}, ThreadMetadata{threadName=stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-3, threadState=RUNNING, activeTasks=[TaskMetadata{taskId=1_0, topicPartitions=[node-name-repartition-0, windowed-node-counts-0]}, TaskMetadata{taskId=3_2, topicPartitions=[k8sName-id-repartition-2]}], standbyTasks=[], consumerClientId=stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-3-consumer, restoreConsumerClientId=stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-3-restore-consumer, producerClientIds=[stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-3-1_0-producer, stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-3-3_2-producer], adminClientId=stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-admin}, ThreadMetadata{threadName=stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1, threadState=RUNNING, activeTasks=[], standbyTasks=[], consumerClientId=stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1-consumer, restoreConsumerClientId=stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-StreamThread-1-restore-consumer, producerClientIds=[], adminClientId=stream-soak-test-262ab0fb-438e-4810-9ef8-c008eaaebcc1-admin}] (org.apache.kafka.streams.StreamsSoakTest)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_broker_i-01d7da642981a9e5d_server-log) [2020-03-20 17:40:16,968] INFO [GroupCoordinator 1003]: Assignment received from leader for group stream-soak-test for generation 655 (kafka.coordinator.group.GroupCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_broker_i-01d7da642981a9e5d_server-log) [2020-03-20 17:40:16,972] INFO [GroupCoordinator 1003]: Member[group.instance.id None, member.id stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-1-consumer-34c2198b-5bdd-470b-ae50-30a39873edab] in group stream-soak-test has left, removing it from the group (kafka.coordinator.group.GroupCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_broker_i-01d7da642981a9e5d_server-log) [2020-03-20 17:40:16,972] INFO [GroupCoordinator 1003]: Preparing to rebalance group stream-soak-test in state PreparingRebalance with old generation 655 (__consumer_offsets-32) (reason: removing member stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-1-consumer-34c2198b-5bdd-470b-ae50-30a39873edab on LeaveGroup) (kafka.coordinator.group.GroupCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_broker_i-01d7da642981a9e5d_stdout) [2020-03-20 17:40:16,968] INFO [GroupCoordinator 1003]: Assignment received from leader for group stream-soak-test for generation 655 (kafka.coordinator.group.GroupCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_broker_i-01d7da642981a9e5d_stdout) [2020-03-20 17:40:16,972] INFO [GroupCoordinator 1003]: Member[group.instance.id None, member.id stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-1-consumer-34c2198b-5bdd-470b-ae50-30a39873edab] in group stream-soak-test has left, removing it from the group (kafka.coordinator.group.GroupCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_broker_i-01d7da642981a9e5d_stdout) [2020-03-20 17:40:16,972] INFO [GroupCoordinator 1003]: Preparing to rebalance group stream-soak-test in state PreparingRebalance with old generation 655 (__consumer_offsets-32) (reason: removing member stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-1-consumer-34c2198b-5bdd-470b-ae50-30a39873edab on LeaveGroup) (kafka.coordinator.group.GroupCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-01629239fa39901b4_streamslog) [2020-03-20 17:40:16,971] INFO [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-3] [Consumer clientId=stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-3-consumer, groupId=stream-soak-test] Successfully joined group with generation 655 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-01629239fa39901b4_streamslog) [2020-03-20 17:40:16,972] INFO [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-3] [Consumer clientId=stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-3-consumer, groupId=stream-soak-test] Updating assignment with
	Assigned partitions:                       [network-id-repartition-1]
	Current owned partitions:                  [network-id-repartition-1]
	Added partitions (assigned - owned):       []
	Revoked partitions (owned - assigned):     []
 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-01629239fa39901b4_streamslog) [2020-03-20 17:40:16,972] INFO [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-3] stream-thread [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-3] Handle new assignment with:
	New active tasks: [2_1]
	New standby tasks: []
	Existing active tasks: [2_1]
	Existing standby tasks: [] (org.apache.kafka.streams.processor.internals.TaskManager)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-01629239fa39901b4_streamslog) [2020-03-20 17:40:16,972] INFO [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-3] [Consumer clientId=stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-3-consumer, groupId=stream-soak-test] Adding newly assigned partitions:  (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-01629239fa39901b4_streamslog) [2020-03-20 17:40:16,972] INFO [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-3] stream-thread [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-3] State transition from RUNNING to PARTITIONS_ASSIGNED (org.apache.kafka.streams.processor.internals.StreamThread)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-01629239fa39901b4_streamslog) [2020-03-20 17:40:16,972] ERROR [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-1] [Consumer clientId=stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-1-consumer, groupId=stream-soak-test] SyncGroup failed due to inconsistent Protocol Name, received stream but expected null (org.apache.kafka.clients.consumer.internals.AbstractCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-01629239fa39901b4_streamslog) [2020-03-20 17:40:16,973] ERROR [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-1] stream-thread [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-1] Encountered the following exception during processing and the thread is going to shut down:  (org.apache.kafka.streams.processor.internals.StreamThread)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-01629239fa39901b4_streamslog) org.apache.kafka.common.errors.InconsistentGroupProtocolException: The group member's supported protocols are incompatible with those of existing members or first group member tried to join with empty protocol type or empty protocol list.
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-01629239fa39901b4_streamslog) [2020-03-20 17:40:16,973] INFO [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-1] stream-thread [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-1] State transition from RUNNING to PENDING_SHUTDOWN (org.apache.kafka.streams.processor.internals.StreamThread)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-01629239fa39901b4_streamslog) [2020-03-20 17:40:16,973] INFO [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-1] stream-thread [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-1] Shutting down (org.apache.kafka.streams.processor.internals.StreamThread)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-01629239fa39901b4_streamslog) [2020-03-20 17:40:16,973] INFO [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-1] [Consumer clientId=stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-1-restore-consumer, groupId=null] Unsubscribed all topics or patterns and assigned partitions (org.apache.kafka.clients.consumer.KafkaConsumer)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-01629239fa39901b4_streamslog) [2020-03-20 17:40:16,973] INFO [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-2] [Consumer clientId=stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-2-consumer, groupId=stream-soak-test] Successfully joined group with generation 655 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-01629239fa39901b4_streamslog) [2020-03-20 17:40:16,974] INFO [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-2] stream-thread [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-2] task [1_2] Restored and ready to run (org.apache.kafka.streams.processor.internals.StreamTask)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-01629239fa39901b4_streamslog) [2020-03-20 17:40:16,974] INFO [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-2] stream-thread [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-2] State transition from PARTITIONS_ASSIGNED to RUNNING (org.apache.kafka.streams.processor.internals.StreamThread)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-01629239fa39901b4_streamslog) [2020-03-20 17:40:16,974] INFO [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-2] [Consumer clientId=stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-2-consumer, groupId=stream-soak-test] Updating assignment with
	Assigned partitions:                       [windowed-node-counts-2, node-name-repartition-2]
	Current owned partitions:                  [windowed-node-counts-2, node-name-repartition-2]
	Added partitions (assigned - owned):       []
	Revoked partitions (owned - assigned):     []
 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-01629239fa39901b4_streamslog) [2020-03-20 17:40:16,975] INFO [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-2] stream-thread [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-2] Handle new assignment with:
	New active tasks: [1_2]
	New standby tasks: []
	Existing active tasks: [1_2]
	Existing standby tasks: [] (org.apache.kafka.streams.processor.internals.TaskManager)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-01629239fa39901b4_streamslog) [2020-03-20 17:40:16,975] INFO [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-2] [Consumer clientId=stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-2-consumer, groupId=stream-soak-test] Adding newly assigned partitions:  (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-01629239fa39901b4_streamslog) [2020-03-20 17:40:16,975] INFO [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-2] stream-thread [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-2] State transition from RUNNING to PARTITIONS_ASSIGNED (org.apache.kafka.streams.processor.internals.StreamThread)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-01629239fa39901b4_streamslog) [2020-03-20 17:40:16,979] INFO [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-1] stream-thread [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-1] State transition from PENDING_SHUTDOWN to DEAD (org.apache.kafka.streams.processor.internals.StreamThread)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-01629239fa39901b4_streamslog) [2020-03-20 17:40:16,979] INFO [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-1] stream-thread [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-1] Shutdown complete (org.apache.kafka.streams.processor.internals.StreamThread)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-01629239fa39901b4_streamslog) [2020-03-20 17:40:16,979] ERROR [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-1] Thread 	StreamsThread threadId: stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-1
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-01629239fa39901b4_streamslog) TaskManager
	MetadataState:
	Tasks:
 encountered an error processing soak test (org.apache.kafka.streams.StreamsSoakTest)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-01629239fa39901b4_streamslog) org.apache.kafka.common.errors.InconsistentGroupProtocolException: The group member's supported protocols are incompatible with those of existing members or first group member tried to join with empty protocol type or empty protocol list.
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-01629239fa39901b4_streamslog) [2020-03-20 17:40:17,013] INFO [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-3] stream-thread [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-3] State transition from PARTITIONS_ASSIGNED to RUNNING (org.apache.kafka.streams.processor.internals.StreamThread)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-01629239fa39901b4_streamslog) [2020-03-20 17:40:17,075] INFO [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-2] stream-thread [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-2] State transition from PARTITIONS_ASSIGNED to RUNNING (org.apache.kafka.streams.processor.internals.StreamThread)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-01629239fa39901b4_streamslog) [2020-03-20 17:40:17,075] INFO [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-2] stream-client [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96] State transition from REBALANCING to RUNNING (org.apache.kafka.streams.KafkaStreams)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-01629239fa39901b4_streamslog) [2020-03-20 17:40:17,075] INFO [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-2] metadata details [ThreadMetadata{threadName=stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-3, threadState=RUNNING, activeTasks=[TaskMetadata{taskId=2_1, topicPartitions=[network-id-repartition-1]}], standbyTasks=[], consumerClientId=stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-3-consumer, restoreConsumerClientId=stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-3-restore-consumer, producerClientIds=[stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-3-2_1-producer], adminClientId=stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-admin}, ThreadMetadata{threadName=stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-1, threadState=DEAD, activeTasks=[], standbyTasks=[], consumerClientId=stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-1-consumer, restoreConsumerClientId=stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-1-restore-consumer, producerClientIds=[], adminClientId=stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-admin}, ThreadMetadata{threadName=stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-2, threadState=RUNNING, activeTasks=[TaskMetadata{taskId=1_2, topicPartitions=[windowed-node-counts-2, node-name-repartition-2]}], standbyTasks=[], consumerClientId=stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-2-consumer, restoreConsumerClientId=stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-2-restore-consumer, producerClientIds=[stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-2-1_2-producer], adminClientId=stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-admin}] (org.apache.kafka.streams.StreamsSoakTest)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-01629239fa39901b4_streamslog) [2020-03-20 17:40:17,151] INFO [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-3] stream-thread [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-3] task [2_1] Prepared task for committing (org.apache.kafka.streams.processor.internals.StreamTask)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-01629239fa39901b4_streamslog) [2020-03-20 17:40:17,157] INFO [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-3] stream-thread [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-3] task [2_1] Committed (org.apache.kafka.streams.processor.internals.StreamTask)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-01629239fa39901b4_streamslog) [2020-03-20 17:40:17,782] INFO [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-2] stream-thread [stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-2] task [1_2] Prepared task for committing (org.apache.kafka.streams.processor.internals.StreamTask)
[2020-03-20T12:40:17-05:00] (streams-soak-trunk-eos_soak_i-01629239fa39901b4_streamslog) [2020-03-20 17:40:17,784] INFO [kafka-producer-network-thread | stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-2-1_2-producer] [Producer clientId=stream-soak-test-f7392d33-55d7-484f-8b72-578e22fead96-StreamThread-2-1_2-producer, transactionalId=stream-soak-test-1_2] Discovered group coordinator ip-172-31-18-29.us-west-2.compute.internal:9092 (id: 1003 rack: null) (org.apache.kafka.clients.producer.internals.TransactionManager)