Details
-
Bug
-
Status: Open
-
Minor
-
Resolution: Unresolved
-
3.7.0
-
None
Description
Error
org.apache.kafka.common.errors.TimeoutException: The query never returned within the bound. Last result: StateQueryResult{partitionResults={0=SucceededQueryResult{result=org.apache.kafka.streams.state.internals.MeteredKeyValueStore$MeteredKeyValueTimestampedIterator@61b360a4, executionInfo=[], position=Position{position={input-topic={0=1}}}}, 1=FailedQueryResult{failureReason=NOT_PRESENT, failure='The requested partition was not present at the time of the query.', executionInfo=[], position=null}}, globalResult=null}
Stacktrace
org.apache.kafka.common.errors.TimeoutException: The query never returned within the bound. Last result: StateQueryResult{partitionResults={0=SucceededQueryResult{result=org.apache.kafka.streams.state.internals.MeteredKeyValueStore$MeteredKeyValueTimestampedIterator@61b360a4, executionInfo=[], position=Position{position={input-topic={0=1}}}}, 1=FailedQueryResult{failureReason=NOT_PRESENT, failure='The requested partition was not present at the time of the query.', executionInfo=[], position=null}}, globalResult=null}
Standard Output
[2023-11-28 22:52:47,353] INFO [Producer clientId=producer-129] Instantiated an idempotent producer. (org.apache.kafka.clients.producer.KafkaProducer:587)
[2023-11-28 22:52:47,466] INFO [Producer clientId=producer-129] ProducerId set to 0 with epoch 0 (org.apache.kafka.clients.producer.internals.TransactionManager:502)
[2023-11-28 22:52:47,473] INFO [Producer clientId=producer-129] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1332)
[2023-11-28 22:52:47,531] INFO stream-client [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57] Kafka Streams version: test-version (org.apache.kafka.streams.KafkaStreams:914)
[2023-11-28 22:52:47,531] INFO stream-client [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57] Kafka Streams commit ID: test-commit-ID (org.apache.kafka.streams.KafkaStreams:915)
[2023-11-28 22:52:47,532] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1] Creating restore consumer client (org.apache.kafka.streams.processor.internals.StreamThread:365)
[2023-11-28 22:52:47,537] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1] Creating thread producer client (org.apache.kafka.streams.processor.internals.StreamThread:105)
[2023-11-28 22:52:47,538] INFO [Producer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-producer] Instantiated an idempotent producer. (org.apache.kafka.clients.producer.KafkaProducer:587)
[2023-11-28 22:52:47,545] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1] Creating consumer client (org.apache.kafka.streams.processor.internals.StreamThread:432)
[2023-11-28 22:52:47,545] INFO state-updater [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StateUpdater-1] State updater thread started (org.apache.kafka.streams.processor.internals.DefaultStateUpdater:135)
[2023-11-28 22:52:47,547] INFO [Producer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-producer] ProducerId set to 1 with epoch 0 (org.apache.kafka.clients.producer.internals.TransactionManager:502)
[2023-11-28 22:52:47,550] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer] Cooperative rebalancing protocol is enabled now (org.apache.kafka.streams.processor.internals.assignment.AssignorConfiguration:141)
[2023-11-28 22:52:47,552] INFO stream-client [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57] State transition from CREATED to REBALANCING (org.apache.kafka.streams.KafkaStreams:339)
[2023-11-28 22:52:47,552] INFO stream-client [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57] Started 1 stream threads (org.apache.kafka.streams.KafkaStreams:1325)
[2023-11-28 22:52:47,553] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1] Starting (org.apache.kafka.streams.processor.internals.StreamThread:621)
[2023-11-28 22:52:47,553] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1] State transition from CREATED to STARTING (org.apache.kafka.streams.processor.internals.StreamThread:241)
[2023-11-28 22:52:47,558] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Subscribed to topic(s): input-topic (org.apache.kafka.clients.consumer.internals.LegacyKafkaConsumer:464)
[2023-11-28 22:52:47,659] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-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:940)
[2023-11-28 22:52:49,671] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Discovered group coordinator localhost:44673 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:919)
[2023-11-28 22:52:49,682] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:589)
[2023-11-28 22:52:49,694] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Request joining group due to: need to re-join with the given member-id: app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer-76e80124-be8b-4ca7-907a-2091955ddc4c (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1085)
[2023-11-28 22:52:49,695] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:589)
[2023-11-28 22:52:49,700] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Successfully joined group with generation Generation
[2023-11-28 22:52:50,304] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer] Skipping the repartition topic validation since there are no repartition topics. (org.apache.kafka.streams.processor.internals.RepartitionTopics:75)
[2023-11-28 22:52:50,972] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer] 1 client nodes and Optional[1] consumers participating in this rebalance:
456895e1-b230-4a83-9164-8e6d65d1fc57: [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer-76e80124-be8b-4ca7-907a-2091955ddc4c]. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:629)
[2023-11-28 22:52:50,972] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer] Assigning stateful tasks: [0_1, 0_0]
and stateless tasks: [] (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:640)
[2023-11-28 22:52:51,089] 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)
[2023-11-28 22:52:51,089] 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)
[2023-11-28 22:52:51,092] INFO Decided on assignment: {456895e1-b230-4a83-9164-8e6d65d1fc57=[activeTasks: ([0_0, 0_1]) standbyTasks: ([]) 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:107)
[2023-11-28 22:52:51,092] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer] Assigned 2 total tasks including 2 stateful tasks to 1 client nodes. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:667)
[2023-11-28 22:52:51,092] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer] Assignment of tasks to nodes: 456895e1-b230-4a83-9164-8e6d65d1fc57=[activeTasks: ([0_0, 0_1]) standbyTasks: ([])] (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:671)
[2023-11-28 22:52:51,093] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer] Client 456895e1-b230-4a83-9164-8e6d65d1fc57 per-consumer assignment:
prev owned active {}
prev owned standby {app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer-76e80124-be8b-4ca7-907a-2091955ddc4c=[]}
assigned active {app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer-76e80124-be8b-4ca7-907a-2091955ddc4c=[0_1, 0_0]}
revoking active {}
assigned standby {}
(org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:904)
[2023-11-28 22:52:51,093] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer] Finished stable assignment of tasks, no followup rebalances required. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:923)
[2023-11-28 22:52:51,093] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Finished assignment for group at generation 1: {app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer-76e80124-be8b-4ca7-907a-2091955ddc4c=Assignment(partitions=[input-topic-0, input-topic-1], userDataSize=135)} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:656)
[2023-11-28 22:52:51,100] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Group coordinator localhost:44673 (id: 2147483647 rack: null) is unavailable or invalid due to cause: session timed out without receiving a heartbeat response. isDisconnected: false. Rediscovery will be attempted. (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:982)
[2023-11-28 22:52:51,101] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Requesting disconnect from last known coordinator localhost:44673 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:995)
[2023-11-28 22:52:51,144] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Discovered group coordinator localhost:44673 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:919)
[2023-11-28 22:52:51,145] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Group coordinator localhost:44673 (id: 2147483647 rack: null) is unavailable or invalid due to cause: coordinator unavailable. isDisconnected: false. Rediscovery will be attempted. (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:982)
[2023-11-28 22:52:51,145] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Requesting disconnect from last known coordinator localhost:44673 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:995)
[2023-11-28 22:52:51,246] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Discovered group coordinator localhost:44673 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:919)
[2023-11-28 22:52:51,247] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Request joining group due to: rebalance failed due to 'null' (DisconnectException) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1085)
[2023-11-28 22:52:51,247] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Group coordinator localhost:44673 (id: 2147483647 rack: null) is unavailable or invalid due to cause: coordinator unavailable. isDisconnected: true. Rediscovery will be attempted. (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:982)
[2023-11-28 22:52:51,249] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Discovered group coordinator localhost:44673 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:919)
[2023-11-28 22:52:51,249] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Group coordinator localhost:44673 (id: 2147483647 rack: null) is unavailable or invalid due to cause: coordinator unavailable. isDisconnected: false. Rediscovery will be attempted. (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:982)
[2023-11-28 22:52:51,249] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Requesting disconnect from last known coordinator localhost:44673 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:995)
[2023-11-28 22:52:51,342] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Discovered group coordinator localhost:44673 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:919)
[2023-11-28 22:52:51,342] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Group coordinator localhost:44673 (id: 2147483647 rack: null) is unavailable or invalid due to cause: coordinator unavailable. isDisconnected: false. Rediscovery will be attempted. (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:982)
[2023-11-28 22:52:51,342] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Requesting disconnect from last known coordinator localhost:44673 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:995)
[2023-11-28 22:52:51,346] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Discovered group coordinator localhost:44673 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:919)
[2023-11-28 22:52:51,347] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:589)
[2023-11-28 22:52:51,351] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] JoinGroup failed: The coordinator is not aware of this member. Need to re-join the group. Sent generation was Generation{generationId=1, memberId='app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer-76e80124-be8b-4ca7-907a-2091955ddc4c', protocol='stream'}
(org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:665)
[2023-11-28 22:52:51,351] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Resetting generation and member id due to: encountered UNKNOWN_MEMBER_ID from JOIN_GROUP response (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1038)
[2023-11-28 22:52:51,352] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Request joining group due to: encountered UNKNOWN_MEMBER_ID from JOIN_GROUP response (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1085)
[2023-11-28 22:52:51,352] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Request joining group due to: rebalance failed due to 'The coordinator is not aware of this member.' (UnknownMemberIdException) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1085)
[2023-11-28 22:52:51,352] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:589)
[2023-11-28 22:52:51,354] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Request joining group due to: need to re-join with the given member-id: app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer-5422ff62-1672-4412-a812-0787932da9f4 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1085)
[2023-11-28 22:52:51,354] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:589)
[2023-11-28 22:52:51,357] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Successfully joined group with generation Generation
[2023-11-28 22:52:51,358] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer] Skipping the repartition topic validation since there are no repartition topics. (org.apache.kafka.streams.processor.internals.RepartitionTopics:75)
[2023-11-28 22:52:51,362] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer] 1 client nodes and Optional[1] consumers participating in this rebalance:
456895e1-b230-4a83-9164-8e6d65d1fc57: [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer-5422ff62-1672-4412-a812-0787932da9f4]. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:629)
[2023-11-28 22:52:51,363] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer] Assigning stateful tasks: [0_1, 0_0]
and stateless tasks: [] (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:640)
[2023-11-28 22:52:51,363] 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)
[2023-11-28 22:52:51,365] 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)
[2023-11-28 22:52:51,365] INFO Decided on assignment: {456895e1-b230-4a83-9164-8e6d65d1fc57=[activeTasks: ([0_0, 0_1]) standbyTasks: ([]) 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:107)
[2023-11-28 22:52:51,366] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer] Assigned 2 total tasks including 2 stateful tasks to 1 client nodes. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:667)
[2023-11-28 22:52:51,366] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer] Assignment of tasks to nodes: 456895e1-b230-4a83-9164-8e6d65d1fc57=[activeTasks: ([0_0, 0_1]) standbyTasks: ([])] (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:671)
[2023-11-28 22:52:51,366] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer] Client 456895e1-b230-4a83-9164-8e6d65d1fc57 per-consumer assignment:
prev owned active {}
prev owned standby {app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer-5422ff62-1672-4412-a812-0787932da9f4=[]}
assigned active {app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer-5422ff62-1672-4412-a812-0787932da9f4=[0_1, 0_0]}
revoking active {}
assigned standby {}
(org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:904)
[2023-11-28 22:52:51,366] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer] Finished stable assignment of tasks, no followup rebalances required. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:923)
[2023-11-28 22:52:51,367] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Finished assignment for group at generation 3: {app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer-5422ff62-1672-4412-a812-0787932da9f4=Assignment(partitions=[input-topic-0, input-topic-1], userDataSize=135)} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:656)
[2023-11-28 22:52:51,381] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Successfully synced group in generation Generation{generationId=3, memberId='app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer-5422ff62-1672-4412-a812-0787932da9f4', protocol='stream'}
(org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:825)
[2023-11-28 22:52:51,422] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Updating assignment with
Assigned partitions: [input-topic-0, input-topic-1]
Current owned partitions: []
Added partitions (assigned - owned): [input-topic-0, input-topic-1]
Revoked partitions (owned - assigned): []
(org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:379)
[2023-11-28 22:52:51,422] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Notifying assignor about the new Assignment(partitions=[input-topic-0, input-topic-1], userDataSize=135) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:316)
[2023-11-28 22:52:51,423] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer] No followup rebalance was requested, resetting the rebalance schedule. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:1404)
[2023-11-28 22:52:51,423] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1] Handle new assignment with:
New active tasks: [0_1, 0_0]
New standby tasks: []
Existing active tasks: []
Existing standby tasks: [] (org.apache.kafka.streams.processor.internals.TaskManager:329)
[2023-11-28 22:52:51,428] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Adding newly assigned partitions: input-topic-0, input-topic-1 (org.apache.kafka.clients.consumer.internals.ConsumerRebalanceListenerInvoker:56)
[2023-11-28 22:52:51,429] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1] State transition from STARTING to PARTITIONS_ASSIGNED (org.apache.kafka.streams.processor.internals.StreamThread:241)
[2023-11-28 22:52:51,430] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Found no committed offset for partition input-topic-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1499)
[2023-11-28 22:52:51,430] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Found no committed offset for partition input-topic-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1499)
[2023-11-28 22:52:51,432] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Resetting offset for partition input-topic-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:44673 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:396)
[2023-11-28 22:52:51,432] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Resetting offset for partition input-topic-1 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:44673 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:396)
[2023-11-28 22:52:51,448] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1] stream-task [0_0] Initializing to the starting offset for changelog app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-kv-store-changelog-0 of in-memory state store kv-store (org.apache.kafka.streams.processor.internals.ProcessorStateManager:253)
[2023-11-28 22:52:51,448] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1] task [0_0] Initialized (org.apache.kafka.streams.processor.internals.StreamTask:267)
[2023-11-28 22:52:51,449] INFO state-updater [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StateUpdater-1] Stateful active task 0_0 was added to the state updater (org.apache.kafka.streams.processor.internals.DefaultStateUpdater:377)
[2023-11-28 22:52:51,454] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1] End offset for changelog app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-kv-store-changelog-0 initialized as 0. (org.apache.kafka.streams.processor.internals.StoreChangelogReader:859)
[2023-11-28 22:52:51,454] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-restore-consumer, groupId=null] Assigned to partition(s): app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-kv-store-changelog-0 (org.apache.kafka.clients.consumer.internals.LegacyKafkaConsumer:562)
[2023-11-28 22:52:51,451] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1] stream-task [0_1] Initializing to the starting offset for changelog app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-kv-store-changelog-1 of in-memory state store kv-store (org.apache.kafka.streams.processor.internals.ProcessorStateManager:253)
[2023-11-28 22:52:51,455] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-restore-consumer, groupId=null] Seeking to earliest offset of partition app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-kv-store-changelog-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState:649)
[2023-11-28 22:52:51,458] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1] task [0_1] Initialized (org.apache.kafka.streams.processor.internals.StreamTask:267)
[2023-11-28 22:52:51,471] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-restore-consumer, groupId=null] Resetting offset for partition app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-kv-store-changelog-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:44673 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:396)
[2023-11-28 22:52:51,572] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1] Finished restoring changelog app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-kv-store-changelog-0 to store kv-store with a total number of 0 records (org.apache.kafka.streams.processor.internals.StoreChangelogReader:680)
[2023-11-28 22:52:51,575] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-restore-consumer, groupId=null] Unsubscribed all topics or patterns and assigned partitions (org.apache.kafka.clients.consumer.internals.LegacyKafkaConsumer:535)
[2023-11-28 22:52:51,575] INFO state-updater [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StateUpdater-1] Stateful active task 0_0 completed restoration (org.apache.kafka.streams.processor.internals.DefaultStateUpdater:456)
[2023-11-28 22:52:51,575] INFO state-updater [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StateUpdater-1] Stateful active task 0_1 was added to the state updater (org.apache.kafka.streams.processor.internals.DefaultStateUpdater:377)
[2023-11-28 22:52:51,578] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1] End offset for changelog app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-kv-store-changelog-1 initialized as 0. (org.apache.kafka.streams.processor.internals.StoreChangelogReader:859)
[2023-11-28 22:52:51,578] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-restore-consumer, groupId=null] Assigned to partition(s): app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-kv-store-changelog-1 (org.apache.kafka.clients.consumer.internals.LegacyKafkaConsumer:562)
[2023-11-28 22:52:51,578] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-restore-consumer, groupId=null] Seeking to earliest offset of partition app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-kv-store-changelog-1 (org.apache.kafka.clients.consumer.internals.SubscriptionState:649)
[2023-11-28 22:52:51,661] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Found no committed offset for partition input-topic-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1499)
[2023-11-28 22:52:51,664] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1] task [0_0] Restored and ready to run (org.apache.kafka.streams.processor.internals.StreamTask:295)
[2023-11-28 22:52:51,876] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-restore-consumer, groupId=null] Resetting offset for partition app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-kv-store-changelog-1 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:44673 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:396)
[2023-11-28 22:52:51,977] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1] Finished restoring changelog app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-kv-store-changelog-1 to store kv-store with a total number of 0 records (org.apache.kafka.streams.processor.internals.StoreChangelogReader:680)
[2023-11-28 22:52:51,979] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-restore-consumer, groupId=null] Unsubscribed all topics or patterns and assigned partitions (org.apache.kafka.clients.consumer.internals.LegacyKafkaConsumer:535)
[2023-11-28 22:52:51,979] INFO state-updater [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StateUpdater-1] Stateful active task 0_1 completed restoration (org.apache.kafka.streams.processor.internals.DefaultStateUpdater:456)
[2023-11-28 22:52:52,025] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Found no committed offset for partition input-topic-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1499)
[2023-11-28 22:52:52,026] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1] task [0_1] Restored and ready to run (org.apache.kafka.streams.processor.internals.StreamTask:295)
[2023-11-28 22:52:52,027] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1] State transition from PARTITIONS_ASSIGNED to RUNNING (org.apache.kafka.streams.processor.internals.StreamThread:241)
[2023-11-28 22:52:52,027] INFO stream-client [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57] State transition from REBALANCING to RUNNING (org.apache.kafka.streams.KafkaStreams:339)
[2023-11-28 22:52:52,128] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL] Requesting the log end offset for input-topic-1 in order to compute lag (org.apache.kafka.clients.consumer.internals.LegacyKafkaConsumer:1030)
[2023-11-28 22:52:52,288] INFO stream-client [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57] State transition from RUNNING to PENDING_SHUTDOWN (org.apache.kafka.streams.KafkaStreams:339)
[2023-11-28 22:52:52,304] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1] Informed to shut down (org.apache.kafka.streams.processor.internals.StreamThread:1299)
[2023-11-28 22:52:52,304] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1] State transition from RUNNING to PENDING_SHUTDOWN (org.apache.kafka.streams.processor.internals.StreamThread:241)
[2023-11-28 22:52:52,305] INFO stream-client [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57] Shutting down 1 stream threads (org.apache.kafka.streams.KafkaStreams:1390)
[2023-11-28 22:52:52,312] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1] Shutting down clean (org.apache.kafka.streams.processor.internals.StreamThread:1313)
[2023-11-28 22:52:52,312] INFO state-updater [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StateUpdater-1] Shutting down state updater thread (org.apache.kafka.streams.processor.internals.DefaultStateUpdater:578)
[2023-11-28 22:52:52,312] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1-restore-consumer, groupId=null] Unsubscribed all topics or patterns and assigned partitions (org.apache.kafka.clients.consumer.internals.LegacyKafkaConsumer:535)
[2023-11-28 22:52:52,313] INFO state-updater [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StateUpdater-1] State updater thread stopped (org.apache.kafka.streams.processor.internals.DefaultStateUpdater:147)
[2023-11-28 22:52:52,314] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1] task [0_0] Suspended from RUNNING (org.apache.kafka.streams.processor.internals.StreamTask:1282)
[2023-11-28 22:52:52,317] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1] stream-task [0_0] Closing record collector clean (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:356)
[2023-11-28 22:52:52,317] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1] task [0_0] Closed clean (org.apache.kafka.streams.processor.internals.StreamTask:568)
[2023-11-28 22:52:52,317] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-true-true-IN_MEMORY_KV-DSL-456895e1-b230-4a83-9164-8e6d65d1fc57-StreamThread-1] task [0
...[truncated 7156182 chars]...
fka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:589)
[2023-11-29 01:35:11,645] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI] Request joining group due to: need to re-join with the given member-id: app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer-ae4139a3-18cf-4cba-a856-88c09c37c7fa (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1085)
[2023-11-29 01:35:11,646] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:589)
[2023-11-29 01:35:11,648] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI] Successfully joined group with generation Generation
[2023-11-29 01:35:11,649] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer] Skipping the repartition topic validation since there are no repartition topics. (org.apache.kafka.streams.processor.internals.RepartitionTopics:75)
[2023-11-29 01:35:11,649] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer] 1 client nodes and Optional[1] consumers participating in this rebalance:
4cbf6f42-b7de-47f4-b601-c050d0588d55: [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer-ae4139a3-18cf-4cba-a856-88c09c37c7fa]. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:629)
[2023-11-29 01:35:11,649] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer] Assigning stateful tasks: []
and stateless tasks: [0_1, 0_0] (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:640)
[2023-11-29 01:35:11,650] INFO Decided on assignment: {4cbf6f42-b7de-47f4-b601-c050d0588d55=[activeTasks: ([0_0, 0_1]) standbyTasks: ([]) prevActiveTasks: ([]) prevStandbyTasks: ([]) changelogOffsetTotalsByTask: ([]) taskLagTotals: ([]) clientTags: ([]) capacity: 1 assigned: 2]} with no followup probing rebalance. (org.apache.kafka.streams.processor.internals.assignment.HighAvailabilityTaskAssignor:107)
[2023-11-29 01:35:11,650] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer] Assigned 2 total tasks including 0 stateful tasks to 1 client nodes. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:667)
[2023-11-29 01:35:11,650] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer] Assignment of tasks to nodes: 4cbf6f42-b7de-47f4-b601-c050d0588d55=[activeTasks: ([0_0, 0_1]) standbyTasks: ([])] (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:671)
[2023-11-29 01:35:11,650] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer] Client 4cbf6f42-b7de-47f4-b601-c050d0588d55 per-consumer assignment:
prev owned active {}
prev owned standby {app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer-ae4139a3-18cf-4cba-a856-88c09c37c7fa=[]}
assigned active {app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer-ae4139a3-18cf-4cba-a856-88c09c37c7fa=[0_1, 0_0]}
revoking active {}
assigned standby {}
(org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:904)
[2023-11-29 01:35:11,650] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer] Finished stable assignment of tasks, no followup rebalances required. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:923)
[2023-11-29 01:35:11,650] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI] Finished assignment for group at generation 1: {app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer-ae4139a3-18cf-4cba-a856-88c09c37c7fa=Assignment(partitions=[input-topic-0, input-topic-1], userDataSize=135)} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:656)
[2023-11-29 01:35:11,653] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI] Successfully synced group in generation Generation{generationId=1, memberId='app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer-ae4139a3-18cf-4cba-a856-88c09c37c7fa', protocol='stream'}
(org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:825)
[2023-11-29 01:35:11,653] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI] Updating assignment with
Assigned partitions: [input-topic-0, input-topic-1]
Current owned partitions: []
Added partitions (assigned - owned): [input-topic-0, input-topic-1]
Revoked partitions (owned - assigned): []
(org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:379)
[2023-11-29 01:35:11,653] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI] Notifying assignor about the new Assignment(partitions=[input-topic-0, input-topic-1], userDataSize=135) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:316)
[2023-11-29 01:35:11,653] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer] No followup rebalance was requested, resetting the rebalance schedule. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:1404)
[2023-11-29 01:35:11,653] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] Handle new assignment with:
New active tasks: [0_1, 0_0]
New standby tasks: []
Existing active tasks: []
Existing standby tasks: [] (org.apache.kafka.streams.processor.internals.TaskManager:329)
[2023-11-29 01:35:11,657] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI] Adding newly assigned partitions: input-topic-0, input-topic-1 (org.apache.kafka.clients.consumer.internals.ConsumerRebalanceListenerInvoker:56)
[2023-11-29 01:35:11,657] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] State transition from STARTING to PARTITIONS_ASSIGNED (org.apache.kafka.streams.processor.internals.StreamThread:241)
[2023-11-29 01:35:11,658] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI] Found no committed offset for partition input-topic-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1499)
[2023-11-29 01:35:11,658] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI] Found no committed offset for partition input-topic-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1499)
[2023-11-29 01:35:11,661] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI] Resetting offset for partition input-topic-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:43341 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:396)
[2023-11-29 01:35:11,662] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI] Resetting offset for partition input-topic-1 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:43341 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState:396)
[2023-11-29 01:35:11,742] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] stream-task [0_0] State store kv-store is not logged and hence would not be restored (org.apache.kafka.streams.processor.internals.ProcessorStateManager:251)
[2023-11-29 01:35:11,742] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] task [0_0] Initialized (org.apache.kafka.streams.processor.internals.StreamTask:267)
[2023-11-29 01:35:11,743] INFO state-updater [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StateUpdater-1] Stateless active task 0_0 was added to the restored tasks of the state updater (org.apache.kafka.streams.processor.internals.DefaultStateUpdater:367)
[2023-11-29 01:35:11,747] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] stream-task [0_1] State store kv-store is not logged and hence would not be restored (org.apache.kafka.streams.processor.internals.ProcessorStateManager:251)
[2023-11-29 01:35:11,747] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] task [0_1] Initialized (org.apache.kafka.streams.processor.internals.StreamTask:267)
[2023-11-29 01:35:11,747] INFO state-updater [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StateUpdater-1] Stateless active task 0_1 was added to the restored tasks of the state updater (org.apache.kafka.streams.processor.internals.DefaultStateUpdater:367)
[2023-11-29 01:35:11,748] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI] Found no committed offset for partition input-topic-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1499)
[2023-11-29 01:35:11,749] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] task [0_0] Restored and ready to run (org.apache.kafka.streams.processor.internals.StreamTask:295)
[2023-11-29 01:35:11,749] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-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:940)
[2023-11-29 01:35:11,753] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI] Found no committed offset for partition input-topic-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1499)
[2023-11-29 01:35:11,753] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] task [0_1] Restored and ready to run (org.apache.kafka.streams.processor.internals.StreamTask:295)
[2023-11-29 01:35:11,753] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] State transition from PARTITIONS_ASSIGNED to RUNNING (org.apache.kafka.streams.processor.internals.StreamThread:241)
[2023-11-29 01:35:11,754] INFO stream-client [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55] State transition from REBALANCING to RUNNING (org.apache.kafka.streams.KafkaStreams:339)
[2023-11-29 01:35:12,640] INFO stream-client [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55] State transition from RUNNING to PENDING_SHUTDOWN (org.apache.kafka.streams.KafkaStreams:339)
[2023-11-29 01:35:12,641] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] Informed to shut down (org.apache.kafka.streams.processor.internals.StreamThread:1299)
[2023-11-29 01:35:12,642] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] State transition from RUNNING to PENDING_SHUTDOWN (org.apache.kafka.streams.processor.internals.StreamThread:241)
[2023-11-29 01:35:12,642] INFO stream-client [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55] Shutting down 1 stream threads (org.apache.kafka.streams.KafkaStreams:1390)
[2023-11-29 01:35:12,643] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] Shutting down clean (org.apache.kafka.streams.processor.internals.StreamThread:1313)
[2023-11-29 01:35:12,643] INFO state-updater [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StateUpdater-1] Shutting down state updater thread (org.apache.kafka.streams.processor.internals.DefaultStateUpdater:578)
[2023-11-29 01:35:12,644] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-restore-consumer, groupId=null] Unsubscribed all topics or patterns and assigned partitions (org.apache.kafka.clients.consumer.internals.LegacyKafkaConsumer:535)
[2023-11-29 01:35:12,644] INFO state-updater [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StateUpdater-1] State updater thread stopped (org.apache.kafka.streams.processor.internals.DefaultStateUpdater:147)
[2023-11-29 01:35:12,940] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] task [0_0] Suspended from RUNNING (org.apache.kafka.streams.processor.internals.StreamTask:1282)
[2023-11-29 01:35:12,944] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] stream-task [0_0] Closing record collector clean (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:356)
[2023-11-29 01:35:12,944] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] task [0_0] Closed clean (org.apache.kafka.streams.processor.internals.StreamTask:568)
[2023-11-29 01:35:12,945] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] task [0_1] Suspended from RUNNING (org.apache.kafka.streams.processor.internals.StreamTask:1282)
[2023-11-29 01:35:12,949] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] stream-task [0_1] Closing record collector clean (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:356)
[2023-11-29 01:35:12,949] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] task [0_1] Closed clean (org.apache.kafka.streams.processor.internals.StreamTask:568)
[2023-11-29 01:35:12,949] INFO [Producer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-producer] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1332)
[2023-11-29 01:35:12,953] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] Shutdown complete (org.apache.kafka.streams.processor.internals.TaskManager:1382)
[2023-11-29 01:35:12,953] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-restore-consumer, groupId=null] Unsubscribed all topics or patterns and assigned partitions (org.apache.kafka.clients.consumer.internals.LegacyKafkaConsumer:535)
[2023-11-29 01:35:12,961] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] State transition from PENDING_SHUTDOWN to DEAD (org.apache.kafka.streams.processor.internals.StreamThread:241)
[2023-11-29 01:35:12,961] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] Shutdown complete (org.apache.kafka.streams.processor.internals.StreamThread:1352)
[2023-11-29 01:35:12,961] INFO stream-client [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55] Shutdown 1 stream threads complete (org.apache.kafka.streams.KafkaStreams:1412)
[2023-11-29 01:35:12,965] INFO stream-client [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55] State transition from PENDING_SHUTDOWN to NOT_RUNNING (org.apache.kafka.streams.KafkaStreams:339)
[2023-11-29 01:35:12,965] INFO stream-client [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55] Streams client stopped completely (org.apache.kafka.streams.KafkaStreams:1479)
[2023-11-29 01:35:12,967] WARN Using an OS temp directory in the state.dir property can cause failures with writing the checkpoint file due to the fact that this directory can be cleared by the OS. Resolved state.dir: [/tmp/kafka-2585851519486397314] (org.apache.kafka.streams.processor.internals.StateDirectory:138)
[2023-11-29 01:35:12,968] INFO Reading UUID from process file: 4cbf6f42-b7de-47f4-b601-c050d0588d55 (org.apache.kafka.streams.processor.internals.StateDirectory:203)
[2023-11-29 01:35:12,971] INFO stream-client [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55] Kafka Streams version: test-version (org.apache.kafka.streams.KafkaStreams:914)
[2023-11-29 01:35:12,971] INFO stream-client [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55] Kafka Streams commit ID: test-commit-ID (org.apache.kafka.streams.KafkaStreams:915)
[2023-11-29 01:35:12,972] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] Creating restore consumer client (org.apache.kafka.streams.processor.internals.StreamThread:365)
[2023-11-29 01:35:12,975] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] Creating thread producer client (org.apache.kafka.streams.processor.internals.StreamThread:105)
[2023-11-29 01:35:12,976] INFO [Producer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-producer] Instantiated an idempotent producer. (org.apache.kafka.clients.producer.KafkaProducer:587)
[2023-11-29 01:35:12,981] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] Creating consumer client (org.apache.kafka.streams.processor.internals.StreamThread:432)
[2023-11-29 01:35:12,981] INFO state-updater [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StateUpdater-1] State updater thread started (org.apache.kafka.streams.processor.internals.DefaultStateUpdater:135)
[2023-11-29 01:35:12,984] INFO [Producer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-producer] ProducerId set to 112 with epoch 0 (org.apache.kafka.clients.producer.internals.TransactionManager:502)
[2023-11-29 01:35:12,985] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer] Cooperative rebalancing protocol is enabled now (org.apache.kafka.streams.processor.internals.assignment.AssignorConfiguration:141)
[2023-11-29 01:35:12,989] INFO stream-client [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55] State transition from CREATED to REBALANCING (org.apache.kafka.streams.KafkaStreams:339)
[2023-11-29 01:35:12,989] INFO stream-client [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55] Started 1 stream threads (org.apache.kafka.streams.KafkaStreams:1325)
[2023-11-29 01:35:12,989] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] Starting (org.apache.kafka.streams.processor.internals.StreamThread:621)
[2023-11-29 01:35:12,989] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] State transition from CREATED to STARTING (org.apache.kafka.streams.processor.internals.StreamThread:241)
[2023-11-29 01:35:12,990] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI] Subscribed to topic(s): input-topic (org.apache.kafka.clients.consumer.internals.LegacyKafkaConsumer:464)
[2023-11-29 01:35:12,994] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI] Discovered group coordinator localhost:43341 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:919)
[2023-11-29 01:35:12,995] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:589)
[2023-11-29 01:35:12,998] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI] Request joining group due to: need to re-join with the given member-id: app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer-fce73e67-3e59-4ca6-b988-f89f6ef4fd53 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1085)
[2023-11-29 01:35:12,998] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:589)
[2023-11-29 01:35:13,090] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-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:940)
[2023-11-29 01:35:13,857] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI] Successfully joined group with generation Generation
[2023-11-29 01:35:13,857] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer] Skipping the repartition topic validation since there are no repartition topics. (org.apache.kafka.streams.processor.internals.RepartitionTopics:75)
[2023-11-29 01:35:13,858] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer] 1 client nodes and Optional[1] consumers participating in this rebalance:
4cbf6f42-b7de-47f4-b601-c050d0588d55: [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer-fce73e67-3e59-4ca6-b988-f89f6ef4fd53]. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:629)
[2023-11-29 01:35:13,858] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer] Assigning stateful tasks: []
and stateless tasks: [0_1, 0_0] (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:640)
[2023-11-29 01:35:13,858] INFO Decided on assignment: {4cbf6f42-b7de-47f4-b601-c050d0588d55=[activeTasks: ([0_0, 0_1]) standbyTasks: ([]) prevActiveTasks: ([]) prevStandbyTasks: ([]) changelogOffsetTotalsByTask: ([]) taskLagTotals: ([]) clientTags: ([]) capacity: 1 assigned: 2]} with no followup probing rebalance. (org.apache.kafka.streams.processor.internals.assignment.HighAvailabilityTaskAssignor:107)
[2023-11-29 01:35:13,859] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer] Assigned 2 total tasks including 0 stateful tasks to 1 client nodes. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:667)
[2023-11-29 01:35:13,859] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer] Assignment of tasks to nodes: 4cbf6f42-b7de-47f4-b601-c050d0588d55=[activeTasks: ([0_0, 0_1]) standbyTasks: ([])] (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:671)
[2023-11-29 01:35:13,859] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer] Client 4cbf6f42-b7de-47f4-b601-c050d0588d55 per-consumer assignment:
prev owned active {}
prev owned standby {app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer-fce73e67-3e59-4ca6-b988-f89f6ef4fd53=[]}
assigned active {app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer-fce73e67-3e59-4ca6-b988-f89f6ef4fd53=[0_1, 0_0]}
revoking active {}
assigned standby {}
(org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:904)
[2023-11-29 01:35:13,859] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer] Finished stable assignment of tasks, no followup rebalances required. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:923)
[2023-11-29 01:35:13,859] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI] Finished assignment for group at generation 2: {app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer-fce73e67-3e59-4ca6-b988-f89f6ef4fd53=Assignment(partitions=[input-topic-0, input-topic-1], userDataSize=135)} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:656)
[2023-11-29 01:35:13,862] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI] Successfully synced group in generation Generation{generationId=2, memberId='app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer-fce73e67-3e59-4ca6-b988-f89f6ef4fd53', protocol='stream'}
(org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:825)
[2023-11-29 01:35:13,862] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI] Updating assignment with
Assigned partitions: [input-topic-0, input-topic-1]
Current owned partitions: []
Added partitions (assigned - owned): [input-topic-0, input-topic-1]
Revoked partitions (owned - assigned): []
(org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:379)
[2023-11-29 01:35:13,863] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI] Notifying assignor about the new Assignment(partitions=[input-topic-0, input-topic-1], userDataSize=135) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:316)
[2023-11-29 01:35:13,863] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer] No followup rebalance was requested, resetting the rebalance schedule. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor:1404)
[2023-11-29 01:35:13,863] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] Handle new assignment with:
New active tasks: [0_1, 0_0]
New standby tasks: []
Existing active tasks: []
Existing standby tasks: [] (org.apache.kafka.streams.processor.internals.TaskManager:329)
[2023-11-29 01:35:13,867] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI] Adding newly assigned partitions: input-topic-0, input-topic-1 (org.apache.kafka.clients.consumer.internals.ConsumerRebalanceListenerInvoker:56)
[2023-11-29 01:35:13,867] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] State transition from STARTING to PARTITIONS_ASSIGNED (org.apache.kafka.streams.processor.internals.StreamThread:241)
[2023-11-29 01:35:13,869] INFO Setting offset for partition input-topic-0 to the committed offset FetchPosition{offset=2, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:43341 (id: 0 rack: null)], epoch=0}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:193)
[2023-11-29 01:35:13,870] INFO Setting offset for partition input-topic-1 to the committed offset FetchPosition{offset=2, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:43341 (id: 0 rack: null)], epoch=0}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:193)
[2023-11-29 01:35:14,169] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] stream-task [0_0] State store kv-store is not logged and hence would not be restored (org.apache.kafka.streams.processor.internals.ProcessorStateManager:251)
[2023-11-29 01:35:14,170] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] task [0_0] Initialized (org.apache.kafka.streams.processor.internals.StreamTask:267)
[2023-11-29 01:35:14,170] INFO state-updater [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StateUpdater-1] Stateless active task 0_0 was added to the restored tasks of the state updater (org.apache.kafka.streams.processor.internals.DefaultStateUpdater:367)
[2023-11-29 01:35:14,418] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] stream-task [0_1] State store kv-store is not logged and hence would not be restored (org.apache.kafka.streams.processor.internals.ProcessorStateManager:251)
[2023-11-29 01:35:14,418] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] task [0_1] Initialized (org.apache.kafka.streams.processor.internals.StreamTask:267)
[2023-11-29 01:35:14,418] INFO state-updater [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StateUpdater-1] Stateless active task 0_1 was added to the restored tasks of the state updater (org.apache.kafka.streams.processor.internals.DefaultStateUpdater:367)
[2023-11-29 01:35:14,477] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] task [0_0] Restored and ready to run (org.apache.kafka.streams.processor.internals.StreamTask:295)
[2023-11-29 01:35:14,493] INFO stream-client [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55] State transition from REBALANCING to PENDING_SHUTDOWN (org.apache.kafka.streams.KafkaStreams:339)
[2023-11-29 01:35:14,494] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] Informed to shut down (org.apache.kafka.streams.processor.internals.StreamThread:1299)
[2023-11-29 01:35:14,494] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] State transition from PARTITIONS_ASSIGNED to PENDING_SHUTDOWN (org.apache.kafka.streams.processor.internals.StreamThread:241)
[2023-11-29 01:35:14,495] INFO stream-client [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55] Shutting down 1 stream threads (org.apache.kafka.streams.KafkaStreams:1390)
[2023-11-29 01:35:14,578] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI] Requesting the log end offset for input-topic-0 in order to compute lag (org.apache.kafka.clients.consumer.internals.LegacyKafkaConsumer:1030)
[2023-11-29 01:35:14,578] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] Shutting down clean (org.apache.kafka.streams.processor.internals.StreamThread:1313)
[2023-11-29 01:35:14,578] INFO state-updater [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StateUpdater-1] Shutting down state updater thread (org.apache.kafka.streams.processor.internals.DefaultStateUpdater:578)
[2023-11-29 01:35:14,578] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-restore-consumer, groupId=null] Unsubscribed all topics or patterns and assigned partitions (org.apache.kafka.clients.consumer.internals.LegacyKafkaConsumer:535)
[2023-11-29 01:35:14,579] INFO state-updater [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StateUpdater-1] State updater thread stopped (org.apache.kafka.streams.processor.internals.DefaultStateUpdater:147)
[2023-11-29 01:35:14,670] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] task [0_0] Suspended from RUNNING (org.apache.kafka.streams.processor.internals.StreamTask:1282)
[2023-11-29 01:35:14,675] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] stream-task [0_0] Closing record collector clean (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:356)
[2023-11-29 01:35:14,675] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] task [0_0] Closed clean (org.apache.kafka.streams.processor.internals.StreamTask:568)
[2023-11-29 01:35:14,676] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] task [0_1] Suspended from RESTORING (org.apache.kafka.streams.processor.internals.StreamTask:1282)
[2023-11-29 01:35:14,680] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] stream-task [0_1] Closing record collector clean (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:356)
[2023-11-29 01:35:14,680] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] task [0_1] Closed clean (org.apache.kafka.streams.processor.internals.StreamTask:568)
[2023-11-29 01:35:14,681] INFO [Producer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-producer] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1332)
[2023-11-29 01:35:14,684] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] Shutdown complete (org.apache.kafka.streams.processor.internals.TaskManager:1382)
[2023-11-29 01:35:14,684] INFO [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-restore-consumer, groupId=null] Unsubscribed all topics or patterns and assigned partitions (org.apache.kafka.clients.consumer.internals.LegacyKafkaConsumer:535)
[2023-11-29 01:35:14,981] ERROR [Consumer clientId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1-consumer, groupId=app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI] Unable to find FetchSessionHandler for node 0. Ignoring fetch response. (org.apache.kafka.clients.consumer.internals.AbstractFetch:150)
[2023-11-29 01:35:14,990] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] State transition from PENDING_SHUTDOWN to DEAD (org.apache.kafka.streams.processor.internals.StreamThread:241)
[2023-11-29 01:35:14,990] INFO stream-thread [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55-StreamThread-1] Shutdown complete (org.apache.kafka.streams.processor.internals.StreamThread:1352)
[2023-11-29 01:35:14,990] INFO stream-client [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55] Shutdown 1 stream threads complete (org.apache.kafka.streams.KafkaStreams:1412)
[2023-11-29 01:35:14,995] INFO stream-client [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55] State transition from PENDING_SHUTDOWN to NOT_RUNNING (org.apache.kafka.streams.KafkaStreams:339)
[2023-11-29 01:35:14,995] INFO stream-client [app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI-4cbf6f42-b7de-47f4-b601-c050d0588d55] Streams client stopped completely (org.apache.kafka.streams.KafkaStreams:1479)
[2023-11-29 01:35:14,996] INFO stream-thread [Time-limited test] Deleting task directory 0_0 for 0_0 as user calling cleanup. (org.apache.kafka.streams.processor.internals.StateDirectory:554)
[2023-11-29 01:35:14,997] INFO stream-thread [Time-limited test] Deleting task directory 0_1 for 0_1 as user calling cleanup. (org.apache.kafka.streams.processor.internals.StateDirectory:554)
[2023-11-29 01:35:14,999] WARN stream-thread [Time-limited test] Failed to delete state store directory of /tmp/kafka-2585851519486397314/app-org.apache.kafka.streams.integration.PositionRestartIntegrationTest-false-false-ROCKS_SESSION-PAPI for it is not empty (org.apache.kafka.streams.processor.internals.StateDirectory:422)