Andrew Schofield created KAFKA-15944:
----------------------------------------
Summary: 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
Affects Versions: 3.7.0
Reporter: Andrew Schofield
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)
