{\rtf1\ansi\ansicpg1252\cocoartf2580
\cocoatextscaling0\cocoaplatform0{\fonttbl\f0\fswiss\fcharset0 Helvetica;}
{\colortbl;\red255\green255\blue255;}
{\*\expandedcolortbl;;}
\margl1440\margr1440\vieww11520\viewh8400\viewkind0
\pard\tx720\tx1440\tx2160\tx2880\tx3600\tx4320\tx5040\tx5760\tx6480\tx7200\tx7920\tx8640\pardirnatural\partightenfactor0

\f0\fs24 \cf0 [2022-11-10 01:51:15,129] INFO [Producer clientId=producer-1] Instantiated an idempotent producer. (org.apache.kafka.clients.producer.KafkaProducer:593)\
[2022-11-10 01:51:15,174] INFO [Producer clientId=producer-1] ProducerId set to 0 with epoch 0 (org.apache.kafka.clients.producer.internals.TransactionManager:440)\
[2022-11-10 01:51:15,263] INFO [Producer clientId=producer-1] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1307)\
[2022-11-10 01:51:15,368] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938] Kafka Streams version: test-version (org.apache.kafka.streams.KafkaStreams:900)\
[2022-11-10 01:51:15,369] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938] Kafka Streams commit ID: test-commit-ID (org.apache.kafka.streams.KafkaStreams:901)\
[2022-11-10 01:51:15,388] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1] Creating restore consumer client (org.apache.kafka.streams.processor.internals.StreamThread:353)\
[2022-11-10 01:51:15,418] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1] Creating thread producer client (org.apache.kafka.streams.processor.internals.StreamThread:101)\
[2022-11-10 01:51:15,423] INFO [Producer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-producer] Instantiated an idempotent producer. (org.apache.kafka.clients.producer.KafkaProducer:593)\
[2022-11-10 01:51:15,430] INFO [Producer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-producer] ProducerId set to 1 with epoch 0 (org.apache.kafka.clients.producer.internals.TransactionManager:440)\
[2022-11-10 01:51:15,434] INFO state-updater [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StateUpdater-1] State updater thread started (org.apache.kafka.streams.processor.internals.DefaultStateUpdater:97)\
[2022-11-10 01:51:15,436] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1] Creating consumer client (org.apache.kafka.streams.processor.internals.StreamThread:408)\
[2022-11-10 01:51:15,451] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer] Cooperative rebalancing protocol is enabled now (org.apache.kafka.streams.processor.internals.assignment.AssignorConfiguration:136)\
[2022-11-10 01:51:15,480] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b] Kafka Streams version: test-version (org.apache.kafka.streams.KafkaStreams:900)\
[2022-11-10 01:51:15,480] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b] Kafka Streams commit ID: test-commit-ID (org.apache.kafka.streams.KafkaStreams:901)\
[2022-11-10 01:51:15,481] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1] Creating restore consumer client (org.apache.kafka.streams.processor.internals.StreamThread:353)\
[2022-11-10 01:51:15,485] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1] Creating thread producer client (org.apache.kafka.streams.processor.internals.StreamThread:101)\
[2022-11-10 01:51:15,486] INFO [Producer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-producer] Instantiated an idempotent producer. (org.apache.kafka.clients.producer.KafkaProducer:593)\
[2022-11-10 01:51:15,489] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1] Creating consumer client (org.apache.kafka.streams.processor.internals.StreamThread:408)\
[2022-11-10 01:51:15,489] INFO state-updater [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StateUpdater-1] State updater thread started (org.apache.kafka.streams.processor.internals.DefaultStateUpdater:97)\
[2022-11-10 01:51:15,493] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-consumer] Cooperative rebalancing protocol is enabled now (org.apache.kafka.streams.processor.internals.assignment.AssignorConfiguration:136)\
[2022-11-10 01:51:15,493] INFO [Producer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-producer] ProducerId set to 2 with epoch 0 (org.apache.kafka.clients.producer.internals.TransactionManager:440)\
[2022-11-10 01:51:15,498] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938] State transition from CREATED to REBALANCING (org.apache.kafka.streams.KafkaStreams:341)\
[2022-11-10 01:51:15,499] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938] Started 1 stream threads (org.apache.kafka.streams.KafkaStreams:1299)\
[2022-11-10 01:51:15,499] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1] Starting (org.apache.kafka.streams.processor.internals.StreamThread:568)\
[2022-11-10 01:51:15,500] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1] State transition from CREATED to STARTING (org.apache.kafka.streams.processor.internals.StreamThread:236)\
[2022-11-10 01:51:15,500] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b] State transition from CREATED to REBALANCING (org.apache.kafka.streams.KafkaStreams:341)\
[2022-11-10 01:51:15,501] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b] Started 1 stream threads (org.apache.kafka.streams.KafkaStreams:1299)\
[2022-11-10 01:51:15,501] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Subscribed to topic(s): RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-input-stream (org.apache.kafka.clients.consumer.KafkaConsumer:968)\
[2022-11-10 01:51:15,501] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1] Starting (org.apache.kafka.streams.processor.internals.StreamThread:568)\
[2022-11-10 01:51:15,501] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1] State transition from CREATED to STARTING (org.apache.kafka.streams.processor.internals.StreamThread:236)\
[2022-11-10 01:51:15,502] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Subscribed to topic(s): RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-input-stream (org.apache.kafka.clients.consumer.KafkaConsumer:968)\
[2022-11-10 01:51:15,644] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1] Processed 0 total records, ran 0 punctuators, and committed 0 total tasks since the last update (org.apache.kafka.streams.processor.internals.StreamThread:868)\
[2022-11-10 01:51:15,644] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1] Processed 0 total records, ran 0 punctuators, and committed 0 total tasks since the last update (org.apache.kafka.streams.processor.internals.StreamThread:868)\
[2022-11-10 01:51:15,851] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Discovered group coordinator localhost:55873 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:896)\
[2022-11-10 01:51:15,852] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Discovered group coordinator localhost:55873 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:896)\
[2022-11-10 01:51:15,853] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:566)\
[2022-11-10 01:51:15,854] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:566)\
[2022-11-10 01:51:15,884] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Request joining group due to: need to re-join with the given member-id: RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-consumer-eab479a8-7aa6-4abb-a770-a8d198f7ee00 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1062)\
[2022-11-10 01:51:15,885] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Request joining group due to: need to re-join with the given member-id: RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer-c7f228c9-3ebf-46ba-ac40-e0e1ae74bc45 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1062)\
[2022-11-10 01:51:15,885] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Request joining group due to: rebalance failed due to 'The group member needs to have a valid member id before actually entering a consumer group.' (MemberIdRequiredException) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1062)\
[2022-11-10 01:51:15,885] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Request joining group due to: rebalance failed due to 'The group member needs to have a valid member id before actually entering a consumer group.' (MemberIdRequiredException) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1062)\
[2022-11-10 01:51:15,885] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:566)\
[2022-11-10 01:51:15,885] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:566)\
[2022-11-10 01:51:15,899] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Successfully joined group with generation Generation\{generationId=1, memberId='RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-consumer-eab479a8-7aa6-4abb-a770-a8d198f7ee00', protocol='stream'\} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:627)\
[2022-11-10 01:51:15,900] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Successfully joined group with generation Generation\{generationId=1, memberId='RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer-c7f228c9-3ebf-46ba-ac40-e0e1ae74bc45', protocol='stream'\} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:627)\
[2022-11-10 01:51:15,909] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer] Skipping the repartition topic validation since there are no repartition topics. (org.apache.kafka.streams.processor.internals.RepartitionTopics:75)\
[2022-11-10 01:51:16,067] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer] All members participating in this rebalance: \
0d260f84-364d-4f62-b1d3-f7d5dbb4856b: [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-consumer-eab479a8-7aa6-4abb-a770-a8d198f7ee00]\
000896b1-6ee9-4166-8a93-2847f3314938: [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer-c7f228c9-3ebf-46ba-ac40-e0e1ae74bc45]. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:623)\
[2022-11-10 01:51:16,078] INFO Decided on assignment: \{000896b1-6ee9-4166-8a93-2847f3314938=[activeTasks: ([0_0]) standbyTasks: ([0_1]) prevActiveTasks: ([]) prevStandbyTasks: ([]) changelogOffsetTotalsByTask: ([]) taskLagTotals: ([0_0=0, 0_1=0]) clientTags: ([]) capacity: 1 assigned: 2], 0d260f84-364d-4f62-b1d3-f7d5dbb4856b=[activeTasks: ([0_1]) standbyTasks: ([0_0]) prevActiveTasks: ([]) prevStandbyTasks: ([]) changelogOffsetTotalsByTask: ([]) taskLagTotals: ([0_0=0, 0_1=0]) clientTags: ([]) capacity: 1 assigned: 2]\} with no followup probing rebalance. (org.apache.kafka.streams.processor.internals.assignment.HighAvailabilityTaskAssignor:101)\
[2022-11-10 01:51:16,079] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer] Assigned tasks [0_1, 0_0] including stateful [0_1, 0_0] to clients as: \
0d260f84-364d-4f62-b1d3-f7d5dbb4856b=[activeTasks: ([0_1]) standbyTasks: ([0_0])]\
000896b1-6ee9-4166-8a93-2847f3314938=[activeTasks: ([0_0]) standbyTasks: ([0_1])]. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:641)\
[2022-11-10 01:51:16,088] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer] Client 0d260f84-364d-4f62-b1d3-f7d5dbb4856b per-consumer assignment:\
	prev owned active \{\}\
	prev owned standby \{RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-consumer-eab479a8-7aa6-4abb-a770-a8d198f7ee00=[]\}\
	assigned active \{RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-consumer-eab479a8-7aa6-4abb-a770-a8d198f7ee00=[0_1]\}\
	revoking active \{\}\
	assigned standby \{RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-consumer-eab479a8-7aa6-4abb-a770-a8d198f7ee00=[0_0]\}\
 (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:868)\
[2022-11-10 01:51:16,088] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer] Client 000896b1-6ee9-4166-8a93-2847f3314938 per-consumer assignment:\
	prev owned active \{\}\
	prev owned standby \{RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer-c7f228c9-3ebf-46ba-ac40-e0e1ae74bc45=[]\}\
	assigned active \{RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer-c7f228c9-3ebf-46ba-ac40-e0e1ae74bc45=[0_0]\}\
	revoking active \{\}\
	assigned standby \{RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer-c7f228c9-3ebf-46ba-ac40-e0e1ae74bc45=[0_1]\}\
 (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:868)\
[2022-11-10 01:51:16,089] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer] Finished stable assignment of tasks, no followup rebalances required. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:887)\
[2022-11-10 01:51:16,090] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Finished assignment for group at generation 1: \{RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-consumer-eab479a8-7aa6-4abb-a770-a8d198f7ee00=Assignment(partitions=[RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-input-stream-1], userDataSize=183), RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer-c7f228c9-3ebf-46ba-ac40-e0e1ae74bc45=Assignment(partitions=[RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-input-stream-0], userDataSize=183)\} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:705)\
[2022-11-10 01:51:16,107] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Successfully synced group in generation Generation\{generationId=1, memberId='RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer-c7f228c9-3ebf-46ba-ac40-e0e1ae74bc45', protocol='stream'\} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:802)\
[2022-11-10 01:51:16,107] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Successfully synced group in generation Generation\{generationId=1, memberId='RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-consumer-eab479a8-7aa6-4abb-a770-a8d198f7ee00', protocol='stream'\} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:802)\
[2022-11-10 01:51:16,108] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Updating assignment with\
	Assigned partitions:                       [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-input-stream-1]\
	Current owned partitions:                  []\
	Added partitions (assigned - owned):       [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-input-stream-1]\
	Revoked partitions (owned - assigned):     []\
 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:428)\
[2022-11-10 01:51:16,108] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Updating assignment with\
	Assigned partitions:                       [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-input-stream-0]\
	Current owned partitions:                  []\
	Added partitions (assigned - owned):       [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-input-stream-0]\
	Revoked partitions (owned - assigned):     []\
 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:428)\
[2022-11-10 01:51:16,109] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Notifying assignor about the new Assignment(partitions=[RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-input-stream-0], userDataSize=183) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:300)\
[2022-11-10 01:51:16,108] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Notifying assignor about the new Assignment(partitions=[RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-input-stream-1], userDataSize=183) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:300)\
[2022-11-10 01:51:16,110] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer] No followup rebalance was requested, resetting the rebalance schedule. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:1365)\
[2022-11-10 01:51:16,110] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-consumer] No followup rebalance was requested, resetting the rebalance schedule. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:1365)\
[2022-11-10 01:51:16,111] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1] Handle new assignment with:\
	New active tasks: [0_0]\
	New standby tasks: [0_1]\
	Existing active tasks: []\
	Existing standby tasks: [] (org.apache.kafka.streams.processor.internals.TaskManager:309)\
[2022-11-10 01:51:16,111] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1] Handle new assignment with:\
	New active tasks: [0_1]\
	New standby tasks: [0_0]\
	Existing active tasks: []\
	Existing standby tasks: [] (org.apache.kafka.streams.processor.internals.TaskManager:309)\
[2022-11-10 01:51:16,138] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Adding newly assigned partitions: RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-input-stream-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:312)\
[2022-11-10 01:51:16,138] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Adding newly assigned partitions: RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-input-stream-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:312)\
[2022-11-10 01:51:16,139] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1] State transition from STARTING to PARTITIONS_ASSIGNED (org.apache.kafka.streams.processor.internals.StreamThread:236)\
[2022-11-10 01:51:16,139] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1] State transition from STARTING to PARTITIONS_ASSIGNED (org.apache.kafka.streams.processor.internals.StreamThread:236)\
[2022-11-10 01:51:16,150] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Found no committed offset for partition RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-input-stream-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1538)\
[2022-11-10 01:51:16,150] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Found no committed offset for partition RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-input-stream-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1538)\
[2022-11-10 01:51:16,164] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Resetting offset for partition RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-input-stream-0 to position FetchPosition\{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch\{leader=Optional[localhost:55873 (id: 0 rack: null)], epoch=0\}\}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)\
[2022-11-10 01:51:16,169] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1] task [0_1] Initializing to the starting offset for changelog RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-store-changelog-1 of in-memory state store store (org.apache.kafka.streams.processor.internals.ProcessorStateManager:253)\
[2022-11-10 01:51:16,169] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1] task [0_1] Initialized (org.apache.kafka.streams.processor.internals.StreamTask:236)\
[2022-11-10 01:51:16,171] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1] standby-task [0_0] Initializing to the starting offset for changelog RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-store-changelog-0 of in-memory state store store (org.apache.kafka.streams.processor.internals.ProcessorStateManager:253)\
[2022-11-10 01:51:16,171] INFO state-updater [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StateUpdater-1] Stateful active task 0_1 was added to the state updater (org.apache.kafka.streams.processor.internals.DefaultStateUpdater:271)\
[2022-11-10 01:51:16,172] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1] standby-task [0_0] Initialized (org.apache.kafka.streams.processor.internals.StandbyTask:113)\
[2022-11-10 01:51:16,173] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Resetting offset for partition RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-input-stream-1 to position FetchPosition\{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch\{leader=Optional[localhost:55873 (id: 0 rack: null)], epoch=0\}\}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)\
[2022-11-10 01:51:16,182] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-restore-consumer, groupId=null] Assigned to partition(s): RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-store-changelog-1 (org.apache.kafka.clients.consumer.KafkaConsumer:1123)\
[2022-11-10 01:51:16,183] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-restore-consumer, groupId=null] Seeking to earliest offset of partition RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-store-changelog-1 (org.apache.kafka.clients.consumer.internals.SubscriptionState:642)\
[2022-11-10 01:51:16,191] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-restore-consumer, groupId=null] Resetting offset for partition RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-store-changelog-1 to position FetchPosition\{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch\{leader=Optional[localhost:55873 (id: 0 rack: null)], epoch=0\}\}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)\
[2022-11-10 01:51:16,195] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1] task [0_0] Initializing to the starting offset for changelog RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-store-changelog-0 of in-memory state store store (org.apache.kafka.streams.processor.internals.ProcessorStateManager:253)\
[2022-11-10 01:51:16,195] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1] task [0_0] Initialized (org.apache.kafka.streams.processor.internals.StreamTask:236)\
[2022-11-10 01:51:16,195] INFO state-updater [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StateUpdater-1] Stateful active task 0_0 was added to the state updater (org.apache.kafka.streams.processor.internals.DefaultStateUpdater:271)\
[2022-11-10 01:51:16,196] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1] standby-task [0_1] Initializing to the starting offset for changelog RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-store-changelog-1 of in-memory state store store (org.apache.kafka.streams.processor.internals.ProcessorStateManager:253)\
[2022-11-10 01:51:16,197] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1] standby-task [0_1] Initialized (org.apache.kafka.streams.processor.internals.StandbyTask:113)\
[2022-11-10 01:51:16,198] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-restore-consumer, groupId=null] Assigned to partition(s): RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-store-changelog-0 (org.apache.kafka.clients.consumer.KafkaConsumer:1123)\
[2022-11-10 01:51:16,198] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-restore-consumer, groupId=null] Seeking to earliest offset of partition RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-store-changelog-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState:642)\
[2022-11-10 01:51:16,206] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-restore-consumer, groupId=null] Resetting offset for partition RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-store-changelog-0 to position FetchPosition\{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch\{leader=Optional[localhost:55873 (id: 0 rack: null)], epoch=0\}\}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)\
[2022-11-10 01:51:16,297] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1] Finished restoring changelog RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-store-changelog-1 to store store with a total number of 0 records (org.apache.kafka.streams.processor.internals.StoreChangelogReader:672)\
[2022-11-10 01:51:16,298] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-restore-consumer, groupId=null] Unsubscribed all topics or patterns and assigned partitions (org.apache.kafka.clients.consumer.KafkaConsumer:1077)\
[2022-11-10 01:51:16,298] INFO state-updater [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StateUpdater-1] Stateful active task 0_1 completed restoration (org.apache.kafka.streams.processor.internals.DefaultStateUpdater:350)\
[2022-11-10 01:51:16,298] INFO state-updater [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StateUpdater-1] Standby task 0_0 was added to the state updater (org.apache.kafka.streams.processor.internals.DefaultStateUpdater:274)\
[2022-11-10 01:51:16,298] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-restore-consumer, groupId=null] Assigned to partition(s): RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-store-changelog-0 (org.apache.kafka.clients.consumer.KafkaConsumer:1123)\
[2022-11-10 01:51:16,298] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-restore-consumer, groupId=null] Seeking to earliest offset of partition RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-store-changelog-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState:642)\
[2022-11-10 01:51:16,310] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1] Finished restoring changelog RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-store-changelog-0 to store store with a total number of 0 records (org.apache.kafka.streams.processor.internals.StoreChangelogReader:672)\
[2022-11-10 01:51:16,311] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-restore-consumer, groupId=null] Unsubscribed all topics or patterns and assigned partitions (org.apache.kafka.clients.consumer.KafkaConsumer:1077)\
[2022-11-10 01:51:16,311] INFO state-updater [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StateUpdater-1] Stateful active task 0_0 completed restoration (org.apache.kafka.streams.processor.internals.DefaultStateUpdater:350)\
[2022-11-10 01:51:16,311] INFO state-updater [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StateUpdater-1] Standby task 0_1 was added to the state updater (org.apache.kafka.streams.processor.internals.DefaultStateUpdater:274)\
[2022-11-10 01:51:16,311] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-restore-consumer, groupId=null] Assigned to partition(s): RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-store-changelog-1 (org.apache.kafka.clients.consumer.KafkaConsumer:1123)\
[2022-11-10 01:51:16,312] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-restore-consumer, groupId=null] Seeking to earliest offset of partition RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-store-changelog-1 (org.apache.kafka.clients.consumer.internals.SubscriptionState:642)\
[2022-11-10 01:51:16,380] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Found no committed offset for partition RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-input-stream-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1538)\
[2022-11-10 01:51:16,385] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1] task [0_1] Restored and ready to run (org.apache.kafka.streams.processor.internals.StreamTask:261)\
[2022-11-10 01:51:16,385] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1] State transition from PARTITIONS_ASSIGNED to RUNNING (org.apache.kafka.streams.processor.internals.StreamThread:236)\
[2022-11-10 01:51:16,387] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b] State transition from REBALANCING to RUNNING (org.apache.kafka.streams.KafkaStreams:341)\
[2022-11-10 01:51:16,387] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Requesting the log end offset for RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-input-stream-1 in order to compute lag (org.apache.kafka.clients.consumer.KafkaConsumer:2265)\
[2022-11-10 01:51:16,409] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Found no committed offset for partition RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-input-stream-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1538)\
[2022-11-10 01:51:16,410] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1] task [0_0] Restored and ready to run (org.apache.kafka.streams.processor.internals.StreamTask:261)\
[2022-11-10 01:51:16,410] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1] State transition from PARTITIONS_ASSIGNED to RUNNING (org.apache.kafka.streams.processor.internals.StreamThread:236)\
[2022-11-10 01:51:16,410] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938] State transition from REBALANCING to RUNNING (org.apache.kafka.streams.KafkaStreams:341)\
[2022-11-10 01:51:16,410] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Requesting the log end offset for RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-input-stream-0 in order to compute lag (org.apache.kafka.clients.consumer.KafkaConsumer:2265)\
[2022-11-10 01:51:16,538] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-restore-consumer, groupId=null] Resetting offset for partition RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-store-changelog-0 to position FetchPosition\{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch\{leader=Optional[localhost:55873 (id: 0 rack: null)], epoch=0\}\}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)\
[2022-11-10 01:51:16,539] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-restore-consumer, groupId=null] Resetting offset for partition RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-store-changelog-1 to position FetchPosition\{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch\{leader=Optional[localhost:55873 (id: 0 rack: null)], epoch=0\}\}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)\
[2022-11-10 01:51:16,617] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b] State transition from RUNNING to PENDING_SHUTDOWN (org.apache.kafka.streams.KafkaStreams:341)\
[2022-11-10 01:51:16,619] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1] Informed to shut down (org.apache.kafka.streams.processor.internals.StreamThread:1154)\
[2022-11-10 01:51:16,620] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1] State transition from RUNNING to PENDING_SHUTDOWN (org.apache.kafka.streams.processor.internals.StreamThread:236)\
[2022-11-10 01:51:16,620] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b] Shutting down 1 stream threads (org.apache.kafka.streams.KafkaStreams:1364)\
[2022-11-10 01:51:16,720] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1] Shutting down clean (org.apache.kafka.streams.processor.internals.StreamThread:1168)\
[2022-11-10 01:51:16,721] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-restore-consumer, groupId=null] Unsubscribed all topics or patterns and assigned partitions (org.apache.kafka.clients.consumer.KafkaConsumer:1077)\
[2022-11-10 01:51:16,722] INFO state-updater [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StateUpdater-1] State updater thread shutdown (org.apache.kafka.streams.processor.internals.DefaultStateUpdater:112)\
[2022-11-10 01:51:16,742] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1] task [0_1] Suspended from RUNNING (org.apache.kafka.streams.processor.internals.StreamTask:1219)\
[2022-11-10 01:51:16,745] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1] task [0_1] Closing record collector clean (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:316)\
[2022-11-10 01:51:16,745] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1] task [0_1] Closed clean (org.apache.kafka.streams.processor.internals.StreamTask:529)\
[2022-11-10 01:51:16,747] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1] standby-task [0_0] Suspended running (org.apache.kafka.streams.processor.internals.StandbyTask:134)\
[2022-11-10 01:51:16,749] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1] standby-task [0_0] Closed clean (org.apache.kafka.streams.processor.internals.StandbyTask:217)\
[2022-11-10 01:51:16,749] INFO [Producer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-producer] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1307)\
[2022-11-10 01:51:16,753] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1-restore-consumer, groupId=null] Unsubscribed all topics or patterns and assigned partitions (org.apache.kafka.clients.consumer.KafkaConsumer:1077)\
[2022-11-10 01:51:16,758] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1] State transition from PENDING_SHUTDOWN to DEAD (org.apache.kafka.streams.processor.internals.StreamThread:236)\
[2022-11-10 01:51:16,758] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b-StreamThread-1] Shutdown complete (org.apache.kafka.streams.processor.internals.StreamThread:1203)\
[2022-11-10 01:51:16,759] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b] Shutdown 1 stream threads complete (org.apache.kafka.streams.KafkaStreams:1386)\
[2022-11-10 01:51:16,762] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b] State transition from PENDING_SHUTDOWN to NOT_RUNNING (org.apache.kafka.streams.KafkaStreams:341)\
[2022-11-10 01:51:16,762] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-0d260f84-364d-4f62-b1d3-f7d5dbb4856b] Streams client stopped completely (org.apache.kafka.streams.KafkaStreams:1453)\
[2022-11-10 01:52:03,954] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Request joining group due to: group is already rebalancing (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1062)\
[2022-11-10 01:52:03,956] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:566)\
[2022-11-10 01:52:03,958] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Successfully joined group with generation Generation\{generationId=2, memberId='RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer-c7f228c9-3ebf-46ba-ac40-e0e1ae74bc45', protocol='stream'\} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:627)\
[2022-11-10 01:52:03,958] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer] Skipping the repartition topic validation since there are no repartition topics. (org.apache.kafka.streams.processor.internals.RepartitionTopics:75)\
[2022-11-10 01:52:03,963] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer] All members participating in this rebalance: \
000896b1-6ee9-4166-8a93-2847f3314938: [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer-c7f228c9-3ebf-46ba-ac40-e0e1ae74bc45]. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:623)\
[2022-11-10 01:52:03,963] WARN Unable to assign 1 of 1 standby tasks for task [0_0]. There is not enough available capacity. You should increase the number of application instances to maintain the requested number of standby replicas. (org.apache.kafka.streams.processor.internals.assignment.DefaultStandbyTaskAssignor:56)\
[2022-11-10 01:52:03,963] WARN Unable to assign 1 of 1 standby tasks for task [0_1]. There is not enough available capacity. You should increase the number of application instances to maintain the requested number of standby replicas. (org.apache.kafka.streams.processor.internals.assignment.DefaultStandbyTaskAssignor:56)\
[2022-11-10 01:52:03,964] INFO Decided on assignment: \{000896b1-6ee9-4166-8a93-2847f3314938=[activeTasks: ([0_0, 0_1]) standbyTasks: ([]) prevActiveTasks: ([0_0]) prevStandbyTasks: ([]) changelogOffsetTotalsByTask: ([0_0=-2]) taskLagTotals: ([0_0=-2, 0_1=4995]) clientTags: ([]) capacity: 1 assigned: 2]\} with no followup probing rebalance. (org.apache.kafka.streams.processor.internals.assignment.HighAvailabilityTaskAssignor:101)\
[2022-11-10 01:52:03,964] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer] Assigned tasks [0_1, 0_0] including stateful [0_1, 0_0] to clients as: \
000896b1-6ee9-4166-8a93-2847f3314938=[activeTasks: ([0_0, 0_1]) standbyTasks: ([])]. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:641)\
[2022-11-10 01:52:03,964] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer] Client 000896b1-6ee9-4166-8a93-2847f3314938 per-consumer assignment:\
	prev owned active \{RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer-c7f228c9-3ebf-46ba-ac40-e0e1ae74bc45=[0_0]\}\
	prev owned standby \{RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer-c7f228c9-3ebf-46ba-ac40-e0e1ae74bc45=[]\}\
	assigned active \{RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer-c7f228c9-3ebf-46ba-ac40-e0e1ae74bc45=[0_1, 0_0]\}\
	revoking active \{\}\
	assigned standby \{\}\
 (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:868)\
[2022-11-10 01:52:03,964] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer] Finished stable assignment of tasks, no followup rebalances required. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:887)\
[2022-11-10 01:52:03,964] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Finished assignment for group at generation 2: \{RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer-c7f228c9-3ebf-46ba-ac40-e0e1ae74bc45=Assignment(partitions=[RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-input-stream-0, RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-input-stream-1], userDataSize=64)\} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:705)\
[2022-11-10 01:52:03,966] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Successfully synced group in generation Generation\{generationId=2, memberId='RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer-c7f228c9-3ebf-46ba-ac40-e0e1ae74bc45', protocol='stream'\} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:802)\
[2022-11-10 01:52:03,966] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Updating assignment with\
	Assigned partitions:                       [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-input-stream-0, RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-input-stream-1]\
	Current owned partitions:                  [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-input-stream-0]\
	Added partitions (assigned - owned):       [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-input-stream-1]\
	Revoked partitions (owned - assigned):     []\
 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:428)\
[2022-11-10 01:52:03,967] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Notifying assignor about the new Assignment(partitions=[RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-input-stream-0, RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-input-stream-1], userDataSize=64) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:300)\
[2022-11-10 01:52:03,967] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer] No followup rebalance was requested, resetting the rebalance schedule. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:1365)\
[2022-11-10 01:52:03,967] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1] Handle new assignment with:\
	New active tasks: [0_1, 0_0]\
	New standby tasks: []\
	Existing active tasks: [0_0]\
	Existing standby tasks: [] (org.apache.kafka.streams.processor.internals.TaskManager:309)\
[2022-11-10 01:52:03,968] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Adding newly assigned partitions: RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-input-stream-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:312)\
[2022-11-10 01:52:03,968] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1] State transition from RUNNING to PARTITIONS_ASSIGNED (org.apache.kafka.streams.processor.internals.StreamThread:236)\
[2022-11-10 01:52:03,968] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938] State transition from RUNNING to REBALANCING (org.apache.kafka.streams.KafkaStreams:341)\
[2022-11-10 01:52:03,970] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Setting offset for partition RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-input-stream-1 to the committed offset FetchPosition\{offset=4995, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch\{leader=Optional[localhost:55873 (id: 0 rack: null)], epoch=0\}\} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:968)\
[2022-11-10 01:52:04,057] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1] State transition from PARTITIONS_ASSIGNED to RUNNING (org.apache.kafka.streams.processor.internals.StreamThread:236)\
[2022-11-10 01:52:04,057] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938] State transition from REBALANCING to RUNNING (org.apache.kafka.streams.KafkaStreams:341)\
[2022-11-10 01:52:04,065] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-restore-consumer, groupId=null] Unsubscribed all topics or patterns and assigned partitions (org.apache.kafka.clients.consumer.KafkaConsumer:1077)\
[2022-11-10 01:52:04,065] INFO state-updater [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StateUpdater-1] Standby task 0_1 was removed from the updating tasks and added to the removed tasks. (org.apache.kafka.streams.processor.internals.DefaultStateUpdater:294)\
[2022-11-10 01:52:04,162] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1] standby-task [0_1] Suspended running (org.apache.kafka.streams.processor.internals.StandbyTask:134)\
[2022-11-10 01:52:04,162] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1] standby-task [0_1] Closed and recycled state (org.apache.kafka.streams.processor.internals.StandbyTask:239)\
[2022-11-10 01:52:04,163] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1] standby-task [0_1] Initializing to the starting offset for changelog RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-store-changelog-1 of in-memory state store store (org.apache.kafka.streams.processor.internals.ProcessorStateManager:253)\
[2022-11-10 01:52:04,163] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1] task [0_1] Initialized (org.apache.kafka.streams.processor.internals.StreamTask:236)\
[2022-11-10 01:52:04,163] INFO state-updater [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StateUpdater-1] Stateful active task 0_1 was added to the state updater (org.apache.kafka.streams.processor.internals.DefaultStateUpdater:271)\
[2022-11-10 01:52:04,165] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-restore-consumer, groupId=null] Assigned to partition(s): RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-store-changelog-1 (org.apache.kafka.clients.consumer.KafkaConsumer:1123)\
[2022-11-10 01:52:04,165] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-restore-consumer, groupId=null] Seeking to offset 4995 for partition RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-store-changelog-1 (org.apache.kafka.clients.consumer.KafkaConsumer:1594)\
[2022-11-10 01:52:04,270] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1] Finished restoring changelog RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-store-changelog-1 to store store with a total number of 0 records (org.apache.kafka.streams.processor.internals.StoreChangelogReader:672)\
[2022-11-10 01:52:04,270] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-restore-consumer, groupId=null] Unsubscribed all topics or patterns and assigned partitions (org.apache.kafka.clients.consumer.KafkaConsumer:1077)\
[2022-11-10 01:52:04,271] INFO state-updater [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StateUpdater-1] Stateful active task 0_1 completed restoration (org.apache.kafka.streams.processor.internals.DefaultStateUpdater:350)\
[2022-11-10 01:52:04,374] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1] task [0_1] Restored and ready to run (org.apache.kafka.streams.processor.internals.StreamTask:261)\
[2022-11-10 01:52:04,374] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-000896b1-6ee9-4166-8a93-2847f3314938-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true] Requesting the log end offset for RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_1__true-input-stream-1 in order to compute lag (org.apache.kafka.clients.consumer.KafkaConsumer:2265)\
\
Expected all streams instances in [org.apache.kafka.streams.KafkaStreams@32091c14] to be REBALANCING within 60000 ms, but the following were not: \{org.apache.kafka.streams.KafkaStreams@32091c14=RUNNING\}\
java.lang.AssertionError: Expected all streams instances in [org.apache.kafka.streams.KafkaStreams@32091c14] to be REBALANCING within 60000 ms, but the following were not: \{org.apache.kafka.streams.KafkaStreams@32091c14=RUNNING\}\
	at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:26)\
	at org.apache.kafka.streams.integration.utils.IntegrationTestUtils.lambda$waitForApplicationState$12(IntegrationTestUtils.java:1068)\
	at org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:382)\
	at org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:350)\
	at org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitForApplicationState(IntegrationTestUtils.java:1051)\
	at org.apache.kafka.streams.integration.RestoreIntegrationTest.shouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore(RestoreIntegrationTest.java:461)\
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)\
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)\
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)\
	at java.base/java.lang.reflect.Method.invoke(Method.java:568)\
	at org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:727)\
	at org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)\
	at org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)\
	at org.junit.jupiter.engine.extension.SameThreadTimeoutInvocation.proceed(SameThreadTimeoutInvocation.java:45)\
	at org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:156)\
	at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:147)\
	at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestTemplateMethod(TimeoutExtension.java:94)\
	at org.junit.jupiter.engine.execution.InterceptingExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(InterceptingExecutableInvoker.java:103)\
	at org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.lambda$invoke$0(InterceptingExecutableInvoker.java:93)\
	at org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)\
	at org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)\
	at org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)\
	at org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)\
	at org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:92)\
	at org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:86)\
	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$7(TestMethodTestDescriptor.java:217)\
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)\
	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:213)\
	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:138)\
	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:68)\
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)\
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)\
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)\
	at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)\
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)\
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)\
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)\
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)\
	at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:35)\
	at org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:226)\
	at org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:204)\
	at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:142)\
	at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.lambda$execute$2(TestTemplateTestDescriptor.java:110)\
	at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)\
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)\
	at java.base/java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:179)\
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)\
	at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)\
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)\
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)\
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)\
	at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)\
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)\
	at java.base/java.util.Spliterators$ArraySpliterator.forEachRemaining(Spliterators.java:992)\
	at java.base/java.util.stream.ReferencePipeline$Head.forEach(ReferencePipeline.java:762)\
	at java.base/java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:276)\
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)\
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)\
	at java.base/java.util.Spliterators$ArraySpliterator.forEachRemaining(Spliterators.java:992)\
	at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)\
	at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)\
	at java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)\
	at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)\
	at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)\
	at java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596)\
	at java.base/java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:276)\
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)\
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)\
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)\
	at java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1625)\
	at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)\
	at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)\
	at java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)\
	at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)\
	at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)\
	at java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596)\
	at java.base/java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:276)\
	at java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1625)\
	at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)\
	at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)\
	at java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)\
	at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)\
	at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)\
	at java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596)\
	at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:110)\
	at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:44)\
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)\
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)\
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)\
	at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)\
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)\
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)\
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)\
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)\
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)\
	at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)\
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)\
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)\
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)\
	at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)\
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)\
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)\
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)\
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)\
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)\
	at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)\
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)\
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)\
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)\
	at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)\
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)\
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)\
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)\
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)\
	at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:35)\
	at org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57)\
	at org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:54)\
	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)\
	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)\
	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)\
	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)\
	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)\
	at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)\
	at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)\
	at org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)\
	at org.junit.platform.launcher.core.SessionPerRequestLauncher.execute(SessionPerRequestLauncher.java:53)\
	at org.gradle.api.internal.tasks.testing.junitplatform.JUnitPlatformTestClassProcessor$CollectAllTestClassesExecutor.processAllTestClasses(JUnitPlatformTestClassProcessor.java:99)\
	at org.gradle.api.internal.tasks.testing.junitplatform.JUnitPlatformTestClassProcessor$CollectAllTestClassesExecutor.access$000(JUnitPlatformTestClassProcessor.java:79)\
	at org.gradle.api.internal.tasks.testing.junitplatform.JUnitPlatformTestClassProcessor.stop(JUnitPlatformTestClassProcessor.java:75)\
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.stop(SuiteTestClassProcessor.java:61)\
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)\
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)\
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)\
	at java.base/java.lang.reflect.Method.invoke(Method.java:568)\
	at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:36)\
	at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)\
	at org.gradle.internal.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:33)\
	at org.gradle.internal.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:94)\
	at jdk.proxy1/jdk.proxy1.$Proxy2.stop(Unknown Source)\
	at org.gradle.api.internal.tasks.testing.worker.TestWorker$3.run(TestWorker.java:193)\
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.executeAndMaintainThreadName(TestWorker.java:129)\
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.execute(TestWorker.java:100)\
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.execute(TestWorker.java:60)\
	at org.gradle.process.internal.worker.child.ActionExecutionWorker.execute(ActionExecutionWorker.java:56)\
	at org.gradle.process.internal.worker.child.SystemApplicationClassLoaderWorker.call(SystemApplicationClassLoaderWorker.java:133)\
	at org.gradle.process.internal.worker.child.SystemApplicationClassLoaderWorker.call(SystemApplicationClassLoaderWorker.java:71)\
	at worker.org.gradle.process.internal.worker.GradleWorkerMain.run(GradleWorkerMain.java:69)\
	at worker.org.gradle.process.internal.worker.GradleWorkerMain.main(GradleWorkerMain.java:74)\
\
[2022-11-10 01:52:16,941] INFO [Producer clientId=producer-2] Instantiated an idempotent producer. (org.apache.kafka.clients.producer.KafkaProducer:593)\
[2022-11-10 01:52:16,946] INFO [Producer clientId=producer-2] ProducerId set to 3 with epoch 0 (org.apache.kafka.clients.producer.internals.TransactionManager:440)\
[2022-11-10 01:52:16,961] INFO [Producer clientId=producer-2] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1307)\
[2022-11-10 01:52:16,985] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672] Kafka Streams version: test-version (org.apache.kafka.streams.KafkaStreams:900)\
[2022-11-10 01:52:16,985] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672] Kafka Streams commit ID: test-commit-ID (org.apache.kafka.streams.KafkaStreams:901)\
[2022-11-10 01:52:16,986] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] Creating restore consumer client (org.apache.kafka.streams.processor.internals.StreamThread:353)\
[2022-11-10 01:52:16,989] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] Creating thread producer client (org.apache.kafka.streams.processor.internals.StreamThread:101)\
[2022-11-10 01:52:16,991] INFO [Producer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-producer] Instantiated an idempotent producer. (org.apache.kafka.clients.producer.KafkaProducer:593)\
[2022-11-10 01:52:16,993] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] Creating consumer client (org.apache.kafka.streams.processor.internals.StreamThread:408)\
[2022-11-10 01:52:16,996] INFO [Producer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-producer] ProducerId set to 4 with epoch 0 (org.apache.kafka.clients.producer.internals.TransactionManager:440)\
[2022-11-10 01:52:16,996] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer] Cooperative rebalancing protocol is enabled now (org.apache.kafka.streams.processor.internals.assignment.AssignorConfiguration:136)\
[2022-11-10 01:52:17,003] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d] Kafka Streams version: test-version (org.apache.kafka.streams.KafkaStreams:900)\
[2022-11-10 01:52:17,004] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d] Kafka Streams commit ID: test-commit-ID (org.apache.kafka.streams.KafkaStreams:901)\
[2022-11-10 01:52:17,005] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1] Creating restore consumer client (org.apache.kafka.streams.processor.internals.StreamThread:353)\
[2022-11-10 01:52:17,007] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1] Creating thread producer client (org.apache.kafka.streams.processor.internals.StreamThread:101)\
[2022-11-10 01:52:17,009] INFO [Producer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-producer] Instantiated an idempotent producer. (org.apache.kafka.clients.producer.KafkaProducer:593)\
[2022-11-10 01:52:17,011] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1] Creating consumer client (org.apache.kafka.streams.processor.internals.StreamThread:408)\
[2022-11-10 01:52:17,013] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-consumer] Cooperative rebalancing protocol is enabled now (org.apache.kafka.streams.processor.internals.assignment.AssignorConfiguration:136)\
[2022-11-10 01:52:17,014] INFO [Producer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-producer] ProducerId set to 5 with epoch 0 (org.apache.kafka.clients.producer.internals.TransactionManager:440)\
[2022-11-10 01:52:17,016] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672] State transition from CREATED to REBALANCING (org.apache.kafka.streams.KafkaStreams:341)\
[2022-11-10 01:52:17,016] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672] Started 1 stream threads (org.apache.kafka.streams.KafkaStreams:1299)\
[2022-11-10 01:52:17,016] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] Starting (org.apache.kafka.streams.processor.internals.StreamThread:568)\
[2022-11-10 01:52:17,016] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] State transition from CREATED to STARTING (org.apache.kafka.streams.processor.internals.StreamThread:236)\
[2022-11-10 01:52:17,016] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d] State transition from CREATED to REBALANCING (org.apache.kafka.streams.KafkaStreams:341)\
[2022-11-10 01:52:17,017] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Subscribed to topic(s): RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-input-stream (org.apache.kafka.clients.consumer.KafkaConsumer:968)\
[2022-11-10 01:52:17,017] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d] Started 1 stream threads (org.apache.kafka.streams.KafkaStreams:1299)\
[2022-11-10 01:52:17,017] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1] Starting (org.apache.kafka.streams.processor.internals.StreamThread:568)\
[2022-11-10 01:52:17,018] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1] State transition from CREATED to STARTING (org.apache.kafka.streams.processor.internals.StreamThread:236)\
[2022-11-10 01:52:17,018] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Subscribed to topic(s): RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-input-stream (org.apache.kafka.clients.consumer.KafkaConsumer:968)\
[2022-11-10 01:52:17,021] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Discovered group coordinator localhost:55873 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:896)\
[2022-11-10 01:52:17,021] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Discovered group coordinator localhost:55873 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:896)\
[2022-11-10 01:52:17,022] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:566)\
[2022-11-10 01:52:17,022] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:566)\
[2022-11-10 01:52:17,024] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Request joining group due to: need to re-join with the given member-id: RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer-6a6c0954-ad7a-4177-85fa-59c3c4890cea (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1062)\
[2022-11-10 01:52:17,024] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Request joining group due to: need to re-join with the given member-id: RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-consumer-c0964ea0-eaf4-4ac7-a71f-46ab6fb2d282 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1062)\
[2022-11-10 01:52:17,024] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Request joining group due to: rebalance failed due to 'The group member needs to have a valid member id before actually entering a consumer group.' (MemberIdRequiredException) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1062)\
[2022-11-10 01:52:17,024] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Request joining group due to: rebalance failed due to 'The group member needs to have a valid member id before actually entering a consumer group.' (MemberIdRequiredException) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1062)\
[2022-11-10 01:52:17,024] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:566)\
[2022-11-10 01:52:17,025] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:566)\
[2022-11-10 01:52:17,026] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Successfully joined group with generation Generation\{generationId=1, memberId='RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-consumer-c0964ea0-eaf4-4ac7-a71f-46ab6fb2d282', protocol='stream'\} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:627)\
[2022-11-10 01:52:17,026] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Successfully joined group with generation Generation\{generationId=1, memberId='RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer-6a6c0954-ad7a-4177-85fa-59c3c4890cea', protocol='stream'\} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:627)\
[2022-11-10 01:52:17,027] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer] Skipping the repartition topic validation since there are no repartition topics. (org.apache.kafka.streams.processor.internals.RepartitionTopics:75)\
[2022-11-10 01:52:17,120] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1] Processed 0 total records, ran 0 punctuators, and committed 0 total tasks since the last update (org.apache.kafka.streams.processor.internals.StreamThread:868)\
[2022-11-10 01:52:17,153] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer] All members participating in this rebalance: \
1974918e-cb3e-4be7-929b-c7c53b564b3d: [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-consumer-c0964ea0-eaf4-4ac7-a71f-46ab6fb2d282]\
6af47eea-7c44-47b3-b549-c4f206a63672: [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer-6a6c0954-ad7a-4177-85fa-59c3c4890cea]. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:623)\
[2022-11-10 01:52:17,154] INFO Decided on assignment: \{1974918e-cb3e-4be7-929b-c7c53b564b3d=[activeTasks: ([0_0]) standbyTasks: ([0_1]) prevActiveTasks: ([]) prevStandbyTasks: ([]) changelogOffsetTotalsByTask: ([]) taskLagTotals: ([0_0=0, 0_1=0]) clientTags: ([]) capacity: 1 assigned: 2], 6af47eea-7c44-47b3-b549-c4f206a63672=[activeTasks: ([0_1]) standbyTasks: ([0_0]) prevActiveTasks: ([]) prevStandbyTasks: ([]) changelogOffsetTotalsByTask: ([]) taskLagTotals: ([0_0=0, 0_1=0]) clientTags: ([]) capacity: 1 assigned: 2]\} with no followup probing rebalance. (org.apache.kafka.streams.processor.internals.assignment.HighAvailabilityTaskAssignor:101)\
[2022-11-10 01:52:17,154] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer] Assigned tasks [0_1, 0_0] including stateful [0_1, 0_0] to clients as: \
1974918e-cb3e-4be7-929b-c7c53b564b3d=[activeTasks: ([0_0]) standbyTasks: ([0_1])]\
6af47eea-7c44-47b3-b549-c4f206a63672=[activeTasks: ([0_1]) standbyTasks: ([0_0])]. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:641)\
[2022-11-10 01:52:17,154] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer] Client 1974918e-cb3e-4be7-929b-c7c53b564b3d per-consumer assignment:\
	prev owned active \{\}\
	prev owned standby \{RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-consumer-c0964ea0-eaf4-4ac7-a71f-46ab6fb2d282=[]\}\
	assigned active \{RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-consumer-c0964ea0-eaf4-4ac7-a71f-46ab6fb2d282=[0_0]\}\
	revoking active \{\}\
	assigned standby \{RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-consumer-c0964ea0-eaf4-4ac7-a71f-46ab6fb2d282=[0_1]\}\
 (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:868)\
[2022-11-10 01:52:17,155] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer] Client 6af47eea-7c44-47b3-b549-c4f206a63672 per-consumer assignment:\
	prev owned active \{\}\
	prev owned standby \{RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer-6a6c0954-ad7a-4177-85fa-59c3c4890cea=[]\}\
	assigned active \{RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer-6a6c0954-ad7a-4177-85fa-59c3c4890cea=[0_1]\}\
	revoking active \{\}\
	assigned standby \{RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer-6a6c0954-ad7a-4177-85fa-59c3c4890cea=[0_0]\}\
 (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:868)\
[2022-11-10 01:52:17,155] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer] Finished stable assignment of tasks, no followup rebalances required. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:887)\
[2022-11-10 01:52:17,155] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Finished assignment for group at generation 1: \{RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-consumer-c0964ea0-eaf4-4ac7-a71f-46ab6fb2d282=Assignment(partitions=[RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-input-stream-0], userDataSize=184), RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer-6a6c0954-ad7a-4177-85fa-59c3c4890cea=Assignment(partitions=[RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-input-stream-1], userDataSize=184)\} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:705)\
[2022-11-10 01:52:17,155] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] Processed 0 total records, ran 0 punctuators, and committed 0 total tasks since the last update (org.apache.kafka.streams.processor.internals.StreamThread:868)\
[2022-11-10 01:52:17,157] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Successfully synced group in generation Generation\{generationId=1, memberId='RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer-6a6c0954-ad7a-4177-85fa-59c3c4890cea', protocol='stream'\} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:802)\
[2022-11-10 01:52:17,157] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Successfully synced group in generation Generation\{generationId=1, memberId='RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-consumer-c0964ea0-eaf4-4ac7-a71f-46ab6fb2d282', protocol='stream'\} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:802)\
[2022-11-10 01:52:17,157] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Updating assignment with\
	Assigned partitions:                       [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-input-stream-1]\
	Current owned partitions:                  []\
	Added partitions (assigned - owned):       [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-input-stream-1]\
	Revoked partitions (owned - assigned):     []\
 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:428)\
[2022-11-10 01:52:17,157] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Updating assignment with\
	Assigned partitions:                       [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-input-stream-0]\
	Current owned partitions:                  []\
	Added partitions (assigned - owned):       [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-input-stream-0]\
	Revoked partitions (owned - assigned):     []\
 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:428)\
[2022-11-10 01:52:17,157] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Notifying assignor about the new Assignment(partitions=[RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-input-stream-1], userDataSize=184) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:300)\
[2022-11-10 01:52:17,157] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Notifying assignor about the new Assignment(partitions=[RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-input-stream-0], userDataSize=184) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:300)\
[2022-11-10 01:52:17,157] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer] No followup rebalance was requested, resetting the rebalance schedule. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:1365)\
[2022-11-10 01:52:17,158] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-consumer] No followup rebalance was requested, resetting the rebalance schedule. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:1365)\
[2022-11-10 01:52:17,158] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] Handle new assignment with:\
	New active tasks: [0_1]\
	New standby tasks: [0_0]\
	Existing active tasks: []\
	Existing standby tasks: [] (org.apache.kafka.streams.processor.internals.TaskManager:309)\
[2022-11-10 01:52:17,158] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1] Handle new assignment with:\
	New active tasks: [0_0]\
	New standby tasks: [0_1]\
	Existing active tasks: []\
	Existing standby tasks: [] (org.apache.kafka.streams.processor.internals.TaskManager:309)\
[2022-11-10 01:52:17,159] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Adding newly assigned partitions: RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-input-stream-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:312)\
[2022-11-10 01:52:17,160] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1] State transition from STARTING to PARTITIONS_ASSIGNED (org.apache.kafka.streams.processor.internals.StreamThread:236)\
[2022-11-10 01:52:17,159] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Adding newly assigned partitions: RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-input-stream-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:312)\
[2022-11-10 01:52:17,160] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] State transition from STARTING to PARTITIONS_ASSIGNED (org.apache.kafka.streams.processor.internals.StreamThread:236)\
[2022-11-10 01:52:17,161] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Found no committed offset for partition RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-input-stream-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1538)\
[2022-11-10 01:52:17,161] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Found no committed offset for partition RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-input-stream-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1538)\
[2022-11-10 01:52:17,167] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Resetting offset for partition RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-input-stream-1 to position FetchPosition\{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch\{leader=Optional[localhost:55873 (id: 0 rack: null)], epoch=0\}\}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)\
[2022-11-10 01:52:17,167] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Resetting offset for partition RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-input-stream-0 to position FetchPosition\{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch\{leader=Optional[localhost:55873 (id: 0 rack: null)], epoch=0\}\}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)\
[2022-11-10 01:52:17,224] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1] standby-task [0_1] Initializing to the starting offset for changelog RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-store-changelog-1 of in-memory state store store (org.apache.kafka.streams.processor.internals.ProcessorStateManager:253)\
[2022-11-10 01:52:17,224] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1] standby-task [0_1] Initialized (org.apache.kafka.streams.processor.internals.StandbyTask:113)\
[2022-11-10 01:52:17,225] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1] task [0_0] Initializing to the starting offset for changelog RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-store-changelog-0 of in-memory state store store (org.apache.kafka.streams.processor.internals.ProcessorStateManager:253)\
[2022-11-10 01:52:17,225] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1] task [0_0] Initialized (org.apache.kafka.streams.processor.internals.StreamTask:236)\
[2022-11-10 01:52:17,231] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-restore-consumer, groupId=null] Assigned to partition(s): RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-store-changelog-1, RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-store-changelog-0 (org.apache.kafka.clients.consumer.KafkaConsumer:1123)\
[2022-11-10 01:52:17,231] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-restore-consumer, groupId=null] Seeking to earliest offset of partition RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-store-changelog-1 (org.apache.kafka.clients.consumer.internals.SubscriptionState:642)\
[2022-11-10 01:52:17,231] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-restore-consumer, groupId=null] Seeking to earliest offset of partition RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-store-changelog-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState:642)\
[2022-11-10 01:52:17,236] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-restore-consumer, groupId=null] Resetting offset for partition RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-store-changelog-1 to position FetchPosition\{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch\{leader=Optional[localhost:55873 (id: 0 rack: null)], epoch=0\}\}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)\
[2022-11-10 01:52:17,236] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-restore-consumer, groupId=null] Resetting offset for partition RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-store-changelog-0 to position FetchPosition\{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch\{leader=Optional[localhost:55873 (id: 0 rack: null)], epoch=0\}\}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)\
[2022-11-10 01:52:17,261] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] standby-task [0_0] Initializing to the starting offset for changelog RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-store-changelog-0 of in-memory state store store (org.apache.kafka.streams.processor.internals.ProcessorStateManager:253)\
[2022-11-10 01:52:17,262] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] standby-task [0_0] Initialized (org.apache.kafka.streams.processor.internals.StandbyTask:113)\
[2022-11-10 01:52:17,263] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] task [0_1] Initializing to the starting offset for changelog RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-store-changelog-1 of in-memory state store store (org.apache.kafka.streams.processor.internals.ProcessorStateManager:253)\
[2022-11-10 01:52:17,264] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] task [0_1] Initialized (org.apache.kafka.streams.processor.internals.StreamTask:236)\
[2022-11-10 01:52:17,266] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-restore-consumer, groupId=null] Assigned to partition(s): RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-store-changelog-1, RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-store-changelog-0 (org.apache.kafka.clients.consumer.KafkaConsumer:1123)\
[2022-11-10 01:52:17,266] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-restore-consumer, groupId=null] Seeking to earliest offset of partition RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-store-changelog-1 (org.apache.kafka.clients.consumer.internals.SubscriptionState:642)\
[2022-11-10 01:52:17,267] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-restore-consumer, groupId=null] Seeking to earliest offset of partition RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-store-changelog-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState:642)\
[2022-11-10 01:52:17,271] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-restore-consumer, groupId=null] Resetting offset for partition RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-store-changelog-1 to position FetchPosition\{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch\{leader=Optional[localhost:55873 (id: 0 rack: null)], epoch=0\}\}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)\
[2022-11-10 01:52:17,272] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-restore-consumer, groupId=null] Resetting offset for partition RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-store-changelog-0 to position FetchPosition\{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch\{leader=Optional[localhost:55873 (id: 0 rack: null)], epoch=0\}\}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:399)\
[2022-11-10 01:52:17,340] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1] Finished restoring changelog RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-store-changelog-0 to store store with a total number of 0 records (org.apache.kafka.streams.processor.internals.StoreChangelogReader:672)\
[2022-11-10 01:52:17,342] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Found no committed offset for partition RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-input-stream-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1538)\
[2022-11-10 01:52:17,342] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1] task [0_0] Restored and ready to run (org.apache.kafka.streams.processor.internals.StreamTask:261)\
[2022-11-10 01:52:17,342] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1] Restoration took 182 ms for all tasks [0_1, 0_0] (org.apache.kafka.streams.processor.internals.StreamThread:892)\
[2022-11-10 01:52:17,342] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1] State transition from PARTITIONS_ASSIGNED to RUNNING (org.apache.kafka.streams.processor.internals.StreamThread:236)\
[2022-11-10 01:52:17,342] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d] State transition from REBALANCING to RUNNING (org.apache.kafka.streams.KafkaStreams:341)\
[2022-11-10 01:52:17,343] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Requesting the log end offset for RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-input-stream-0 in order to compute lag (org.apache.kafka.clients.consumer.KafkaConsumer:2265)\
[2022-11-10 01:52:17,376] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] Finished restoring changelog RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-store-changelog-1 to store store with a total number of 0 records (org.apache.kafka.streams.processor.internals.StoreChangelogReader:672)\
[2022-11-10 01:52:17,377] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Found no committed offset for partition RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-input-stream-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1538)\
[2022-11-10 01:52:17,377] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] task [0_1] Restored and ready to run (org.apache.kafka.streams.processor.internals.StreamTask:261)\
[2022-11-10 01:52:17,377] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] Restoration took 217 ms for all tasks [0_1, 0_0] (org.apache.kafka.streams.processor.internals.StreamThread:892)\
[2022-11-10 01:52:17,378] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] State transition from PARTITIONS_ASSIGNED to RUNNING (org.apache.kafka.streams.processor.internals.StreamThread:236)\
[2022-11-10 01:52:17,378] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672] State transition from REBALANCING to RUNNING (org.apache.kafka.streams.KafkaStreams:341)\
[2022-11-10 01:52:17,378] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Requesting the log end offset for RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-input-stream-1 in order to compute lag (org.apache.kafka.clients.consumer.KafkaConsumer:2265)\
[2022-11-10 01:52:18,016] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d] State transition from RUNNING to PENDING_SHUTDOWN (org.apache.kafka.streams.KafkaStreams:341)\
[2022-11-10 01:52:18,016] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1] Informed to shut down (org.apache.kafka.streams.processor.internals.StreamThread:1154)\
[2022-11-10 01:52:18,017] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1] State transition from RUNNING to PENDING_SHUTDOWN (org.apache.kafka.streams.processor.internals.StreamThread:236)\
[2022-11-10 01:52:18,017] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d] Shutting down 1 stream threads (org.apache.kafka.streams.KafkaStreams:1364)\
[2022-11-10 01:52:18,017] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1] Shutting down clean (org.apache.kafka.streams.processor.internals.StreamThread:1168)\
[2022-11-10 01:52:18,018] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1] task [0_0] Suspended from RUNNING (org.apache.kafka.streams.processor.internals.StreamTask:1219)\
[2022-11-10 01:52:18,019] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-restore-consumer, groupId=null] Assigned to partition(s): RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-store-changelog-1 (org.apache.kafka.clients.consumer.KafkaConsumer:1123)\
[2022-11-10 01:52:18,019] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1] task [0_0] Closing record collector clean (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:316)\
[2022-11-10 01:52:18,019] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1] task [0_0] Closed clean (org.apache.kafka.streams.processor.internals.StreamTask:529)\
[2022-11-10 01:52:18,019] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1] standby-task [0_1] Suspended running (org.apache.kafka.streams.processor.internals.StandbyTask:134)\
[2022-11-10 01:52:18,020] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-restore-consumer, groupId=null] Unsubscribed all topics or patterns and assigned partitions (org.apache.kafka.clients.consumer.KafkaConsumer:1077)\
[2022-11-10 01:52:18,020] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1] standby-task [0_1] Closed clean (org.apache.kafka.streams.processor.internals.StandbyTask:217)\
[2022-11-10 01:52:18,020] INFO [Producer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-producer] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1307)\
[2022-11-10 01:52:18,021] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1-restore-consumer, groupId=null] Unsubscribed all topics or patterns and assigned partitions (org.apache.kafka.clients.consumer.KafkaConsumer:1077)\
[2022-11-10 01:52:18,023] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1] State transition from PENDING_SHUTDOWN to DEAD (org.apache.kafka.streams.processor.internals.StreamThread:236)\
[2022-11-10 01:52:18,023] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d-StreamThread-1] Shutdown complete (org.apache.kafka.streams.processor.internals.StreamThread:1203)\
[2022-11-10 01:52:18,024] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d] Shutdown 1 stream threads complete (org.apache.kafka.streams.KafkaStreams:1386)\
[2022-11-10 01:52:18,025] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d] State transition from PENDING_SHUTDOWN to NOT_RUNNING (org.apache.kafka.streams.KafkaStreams:341)\
[2022-11-10 01:52:18,025] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-1974918e-cb3e-4be7-929b-c7c53b564b3d] Streams client stopped completely (org.apache.kafka.streams.KafkaStreams:1453)\
[2022-11-10 01:53:05,063] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Request joining group due to: group is already rebalancing (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1062)\
[2022-11-10 01:53:05,064] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:566)\
[2022-11-10 01:53:05,065] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Successfully joined group with generation Generation\{generationId=2, memberId='RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer-6a6c0954-ad7a-4177-85fa-59c3c4890cea', protocol='stream'\} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:627)\
[2022-11-10 01:53:05,065] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer] Skipping the repartition topic validation since there are no repartition topics. (org.apache.kafka.streams.processor.internals.RepartitionTopics:75)\
[2022-11-10 01:53:05,068] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer] All members participating in this rebalance: \
6af47eea-7c44-47b3-b549-c4f206a63672: [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer-6a6c0954-ad7a-4177-85fa-59c3c4890cea]. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:623)\
[2022-11-10 01:53:05,068] WARN Unable to assign 1 of 1 standby tasks for task [0_0]. There is not enough available capacity. You should increase the number of application instances to maintain the requested number of standby replicas. (org.apache.kafka.streams.processor.internals.assignment.DefaultStandbyTaskAssignor:56)\
[2022-11-10 01:53:05,068] WARN Unable to assign 1 of 1 standby tasks for task [0_1]. There is not enough available capacity. You should increase the number of application instances to maintain the requested number of standby replicas. (org.apache.kafka.streams.processor.internals.assignment.DefaultStandbyTaskAssignor:56)\
[2022-11-10 01:53:05,068] INFO Decided on assignment: \{6af47eea-7c44-47b3-b549-c4f206a63672=[activeTasks: ([0_0, 0_1]) standbyTasks: ([]) prevActiveTasks: ([0_1]) prevStandbyTasks: ([0_0]) changelogOffsetTotalsByTask: ([0_0=5005, 0_1=-2]) taskLagTotals: ([0_0=0, 0_1=-2]) clientTags: ([]) capacity: 1 assigned: 2]\} with no followup probing rebalance. (org.apache.kafka.streams.processor.internals.assignment.HighAvailabilityTaskAssignor:101)\
[2022-11-10 01:53:05,068] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer] Assigned tasks [0_1, 0_0] including stateful [0_1, 0_0] to clients as: \
6af47eea-7c44-47b3-b549-c4f206a63672=[activeTasks: ([0_0, 0_1]) standbyTasks: ([])]. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:641)\
[2022-11-10 01:53:05,068] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer] Client 6af47eea-7c44-47b3-b549-c4f206a63672 per-consumer assignment:\
	prev owned active \{RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer-6a6c0954-ad7a-4177-85fa-59c3c4890cea=[0_1]\}\
	prev owned standby \{RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer-6a6c0954-ad7a-4177-85fa-59c3c4890cea=[0_0]\}\
	assigned active \{RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer-6a6c0954-ad7a-4177-85fa-59c3c4890cea=[0_1, 0_0]\}\
	revoking active \{\}\
	assigned standby \{\}\
 (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:868)\
[2022-11-10 01:53:05,068] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer] Finished stable assignment of tasks, no followup rebalances required. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:887)\
[2022-11-10 01:53:05,069] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Finished assignment for group at generation 2: \{RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer-6a6c0954-ad7a-4177-85fa-59c3c4890cea=Assignment(partitions=[RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-input-stream-0, RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-input-stream-1], userDataSize=64)\} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:705)\
[2022-11-10 01:53:05,070] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Successfully synced group in generation Generation\{generationId=2, memberId='RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer-6a6c0954-ad7a-4177-85fa-59c3c4890cea', protocol='stream'\} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:802)\
[2022-11-10 01:53:05,071] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Updating assignment with\
	Assigned partitions:                       [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-input-stream-0, RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-input-stream-1]\
	Current owned partitions:                  [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-input-stream-1]\
	Added partitions (assigned - owned):       [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-input-stream-0]\
	Revoked partitions (owned - assigned):     []\
 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:428)\
[2022-11-10 01:53:05,071] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Notifying assignor about the new Assignment(partitions=[RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-input-stream-0, RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-input-stream-1], userDataSize=64) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:300)\
[2022-11-10 01:53:05,071] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer] No followup rebalance was requested, resetting the rebalance schedule. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:1365)\
[2022-11-10 01:53:05,071] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] Handle new assignment with:\
	New active tasks: [0_1, 0_0]\
	New standby tasks: []\
	Existing active tasks: [0_1]\
	Existing standby tasks: [0_0] (org.apache.kafka.streams.processor.internals.TaskManager:309)\
[2022-11-10 01:53:05,071] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] standby-task [0_0] Suspended running (org.apache.kafka.streams.processor.internals.StandbyTask:134)\
[2022-11-10 01:53:05,072] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-restore-consumer, groupId=null] Assigned to partition(s): RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-store-changelog-1 (org.apache.kafka.clients.consumer.KafkaConsumer:1123)\
[2022-11-10 01:53:05,072] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] standby-task [0_0] Closed and recycled state (org.apache.kafka.streams.processor.internals.StandbyTask:239)\
[2022-11-10 01:53:05,072] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Adding newly assigned partitions: RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-input-stream-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:312)\
[2022-11-10 01:53:05,072] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] State transition from RUNNING to PARTITIONS_ASSIGNED (org.apache.kafka.streams.processor.internals.StreamThread:236)\
[2022-11-10 01:53:05,072] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672] State transition from RUNNING to REBALANCING (org.apache.kafka.streams.KafkaStreams:341)\
[2022-11-10 01:53:05,073] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Setting offset for partition RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-input-stream-0 to the committed offset FetchPosition\{offset=5005, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch\{leader=Optional[localhost:55873 (id: 0 rack: null)], epoch=0\}\} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:968)\
[2022-11-10 01:53:05,146] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] standby-task [0_0] Initializing to the starting offset for changelog RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-store-changelog-0 of in-memory state store store (org.apache.kafka.streams.processor.internals.ProcessorStateManager:253)\
[2022-11-10 01:53:05,147] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] task [0_0] Initialized (org.apache.kafka.streams.processor.internals.StreamTask:236)\
[2022-11-10 01:53:05,149] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-restore-consumer, groupId=null] Assigned to partition(s): RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-store-changelog-1, RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-store-changelog-0 (org.apache.kafka.clients.consumer.KafkaConsumer:1123)\
[2022-11-10 01:53:05,149] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-restore-consumer, groupId=null] Seeking to offset 5005 for partition RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-store-changelog-0 (org.apache.kafka.clients.consumer.KafkaConsumer:1594)\
[2022-11-10 01:53:05,252] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] Finished restoring changelog RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-store-changelog-0 to store store with a total number of 0 records (org.apache.kafka.streams.processor.internals.StoreChangelogReader:672)\
[2022-11-10 01:53:05,254] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] task [0_0] Restored and ready to run (org.apache.kafka.streams.processor.internals.StreamTask:261)\
[2022-11-10 01:53:05,254] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] Restoration took 182 ms for all tasks [0_1, 0_0] (org.apache.kafka.streams.processor.internals.StreamThread:892)\
[2022-11-10 01:53:05,254] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] State transition from PARTITIONS_ASSIGNED to RUNNING (org.apache.kafka.streams.processor.internals.StreamThread:236)\
[2022-11-10 01:53:05,254] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672] State transition from REBALANCING to RUNNING (org.apache.kafka.streams.KafkaStreams:341)\
[2022-11-10 01:53:05,254] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-consumer, groupId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false] Requesting the log end offset for RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-input-stream-0 in order to compute lag (org.apache.kafka.clients.consumer.KafkaConsumer:2265)\
[2022-11-10 01:53:05,357] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672] State transition from RUNNING to PENDING_SHUTDOWN (org.apache.kafka.streams.KafkaStreams:341)\
[2022-11-10 01:53:05,357] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] Informed to shut down (org.apache.kafka.streams.processor.internals.StreamThread:1154)\
[2022-11-10 01:53:05,358] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] State transition from RUNNING to PENDING_SHUTDOWN (org.apache.kafka.streams.processor.internals.StreamThread:236)\
[2022-11-10 01:53:05,358] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672] Shutting down 1 stream threads (org.apache.kafka.streams.KafkaStreams:1364)\
[2022-11-10 01:53:05,358] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] Shutting down clean (org.apache.kafka.streams.processor.internals.StreamThread:1168)\
[2022-11-10 01:53:05,359] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] task [0_0] Suspended from RUNNING (org.apache.kafka.streams.processor.internals.StreamTask:1219)\
[2022-11-10 01:53:05,359] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-restore-consumer, groupId=null] Assigned to partition(s): RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-store-changelog-1 (org.apache.kafka.clients.consumer.KafkaConsumer:1123)\
[2022-11-10 01:53:05,360] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] task [0_0] Closing record collector clean (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:316)\
[2022-11-10 01:53:05,360] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] task [0_0] Closed clean (org.apache.kafka.streams.processor.internals.StreamTask:529)\
[2022-11-10 01:53:05,361] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] task [0_1] Suspended from RUNNING (org.apache.kafka.streams.processor.internals.StreamTask:1219)\
[2022-11-10 01:53:05,362] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-restore-consumer, groupId=null] Unsubscribed all topics or patterns and assigned partitions (org.apache.kafka.clients.consumer.KafkaConsumer:1077)\
[2022-11-10 01:53:05,362] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] task [0_1] Closing record collector clean (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:316)\
[2022-11-10 01:53:05,363] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] task [0_1] Closed clean (org.apache.kafka.streams.processor.internals.StreamTask:529)\
[2022-11-10 01:53:05,363] INFO [Producer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-producer] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1307)\
[2022-11-10 01:53:05,366] INFO [Consumer clientId=RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1-restore-consumer, groupId=null] Unsubscribed all topics or patterns and assigned partitions (org.apache.kafka.clients.consumer.KafkaConsumer:1077)\
[2022-11-10 01:53:05,371] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] State transition from PENDING_SHUTDOWN to DEAD (org.apache.kafka.streams.processor.internals.StreamThread:236)\
[2022-11-10 01:53:05,371] INFO stream-thread [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672-StreamThread-1] Shutdown complete (org.apache.kafka.streams.processor.internals.StreamThread:1203)\
[2022-11-10 01:53:05,371] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672] Shutdown 1 stream threads complete (org.apache.kafka.streams.KafkaStreams:1386)\
[2022-11-10 01:53:05,374] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672] State transition from PENDING_SHUTDOWN to NOT_RUNNING (org.apache.kafka.streams.KafkaStreams:341)\
[2022-11-10 01:53:05,374] INFO stream-client [RestoreIntegrationTestshouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore_2__false-6af47eea-7c44-47b3-b549-c4f206a63672] Streams client stopped completely (org.apache.kafka.streams.KafkaStreams:1453)\
}