ydb/tests/stress/kafka/workload/__init__.py:61: DeprecationWarning: Python 3.14 will, by default, filter extracted tar archives and reject files or modify their metadata. Use the filter argument to control this behavior.
  tar.extractall(path=TEST_FILES_DIRECTORY)
org.apache.kafka.streams.errors.StreamsException: org.apache.kafka.common.KafkaException: Unexpected error in fetch offset response for partition test-topic-4: A request illegally referred to a resource that does not exist.
	at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:653)
	at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:575)
Caused by: org.apache.kafka.common.KafkaException: Unexpected error in fetch offset response for partition test-topic-4: A request illegally referred to a resource that does not exist.
	at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator$OffsetFetchResponseHandler.handle(ConsumerCoordinator.java:1535)
	at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator$OffsetFetchResponseHandler.handle(ConsumerCoordinator.java:1485)
	at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:1260)
	at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:1235)
	at org.apache.kafka.clients.consumer.internals.RequestFuture$1.onSuccess(RequestFuture.java:206)
	at org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:169)
	at org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:129)
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.fireCompletion(ConsumerNetworkClient.java:617)
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.firePendingCompletedRequests(ConsumerNetworkClient.java:427)
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:312)
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:251)
	at org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1307)
	at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1243)
	at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1216)
	at org.apache.kafka.streams.processor.internals.StreamThread.pollRequests(StreamThread.java:1007)
	at org.apache.kafka.streams.processor.internals.StreamThread.pollPhase(StreamThread.java:955)
	at org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:762)
	at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:613)
	... 1 more
org.apache.kafka.streams.errors.StreamsException: org.apache.kafka.common.errors.FencedInstanceIdException: The broker rejected this static consumer since another consumer with the same group.instance.id has registered with a different member.id.
	at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:653)
	at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:575)
Caused by: org.apache.kafka.common.errors.FencedInstanceIdException: The broker rejected this static consumer since another consumer with the same group.instance.id has registered with a different member.id.
2026-03-26T00:36:20.062194Z :WARNING: [/Root]  TraceId []  SessionId [c722221e-28ab11f1-93f4e958-91f99587|b4518352-a38d1eb8-cce54974-2291766d_0]  PartitionId [5] Write session: could not confirm all writes in time or session aborted, perform hard shutdown
Traceback (most recent call last):
  File "contrib/tools/python3/Lib/runpy.py", line 198, in _run_module_as_main
    return _run_code(code, main_globals, None,
                     "__main__", mod_spec)
  File "contrib/tools/python3/Lib/runpy.py", line 88, in _run_code
    exec(code, run_globals)
    ~~~~^^^^^^^^^^^^^^^^^^^
  File "ydb/tests/stress/kafka/__main__.py", line 27, in <module>
    workload.loop()
    ~~~~~~~~~~~~~^^
  File "ydb/tests/stress/kafka/workload/__init__.py", line 122, in loop
    assert totalMessCountTest <= totalMessCountTarget, "Source message count is greater than the target {self.target_topic_path}-{i} topic's message count:" + \
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
AssertionError: Source message count is greater than the target {self.target_topic_path}-{i} topic's message count:1225 and 335 respectively.
contrib/tools/python3/Lib/subprocess.py:1140: ResourceWarning: subprocess 1589421 is still running
ResourceWarning: Enable tracemalloc to get the object allocation traceback
contrib/tools/python3/Lib/subprocess.py:1140: ResourceWarning: subprocess 1589420 is still running
ResourceWarning: Enable tracemalloc to get the object allocation traceback
contrib/tools/python3/Lib/subprocess.py:1140: ResourceWarning: subprocess 1589397 is still running
ResourceWarning: Enable tracemalloc to get the object allocation traceback
contrib/tools/python3/Lib/subprocess.py:1140: ResourceWarning: subprocess 1589396 is still running
ResourceWarning: Enable tracemalloc to get the object allocation traceback
contrib/tools/python3/Lib/subprocess.py:1140: ResourceWarning: subprocess 1589393 is still running
ResourceWarning: Enable tracemalloc to get the object allocation traceback
contrib/tools/python3/Lib/subprocess.py:1140: ResourceWarning: subprocess 1589392 is still running
ResourceWarning: Enable tracemalloc to get the object allocation traceback
