[
https://issues.apache.org/jira/browse/KAFKA-15944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-15944:
------------------------------------
Component/s: unit tests
> Flaky test - verifyStore[cache=false, log=true, supplier=ROCKS_KV, kind=DSL]
> – org.apache.kafka.streams.integration.PositionRestartIntegrationTest
> --------------------------------------------------------------------------------------------------------------------------------------------------
>
> Key: KAFKA-15944
> URL: https://issues.apache.org/jira/browse/KAFKA-15944
> Project: Kafka
> Issue Type: Bug
> Components: streams, unit tests
> Affects Versions: 3.7.0
> Reporter: Andrew Schofield
> Priority: Minor
> Labels: flaky-test
>
> 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{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:650)
> [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{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:650)
> [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{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:650)
> [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{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:650)
> [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)
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
