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: Error encountered trying to commit a transaction [stream-thread [main]]
	at org.apache.kafka.streams.processor.internals.StreamsProducer.commitTransaction(StreamsProducer.java:313)
	at org.apache.kafka.streams.processor.internals.TaskExecutor.commitOffsetsOrTransaction(TaskExecutor.java:203)
	at org.apache.kafka.streams.processor.internals.TaskExecutor.commitTasksAndMaybeUpdateCommittableOffsets(TaskExecutor.java:154)
	at org.apache.kafka.streams.processor.internals.TaskManager.commitTasksAndMaybeUpdateCommittableOffsets(TaskManager.java:1639)
	at org.apache.kafka.streams.processor.internals.TaskManager.commit(TaskManager.java:1607)
	at org.apache.kafka.streams.processor.internals.StreamThread.maybeCommit(StreamThread.java:1109)
	at org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:829)
	at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:613)
	at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:575)
Caused by: org.apache.kafka.common.KafkaException: Unhandled error in EndTxnResponse: The broker is not available.
	at org.apache.kafka.clients.producer.internals.TransactionManager$EndTxnHandler.handleResponse(TransactionManager.java:1531)
	at org.apache.kafka.clients.producer.internals.TransactionManager$TxnRequestHandler.onComplete(TransactionManager.java:1207)
	at org.apache.kafka.clients.ClientResponse.onComplete(ClientResponse.java:109)
	at org.apache.kafka.clients.NetworkClient.completeResponses(NetworkClient.java:583)
	at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:575)
	at org.apache.kafka.clients.producer.internals.Sender.maybeSendAndPollTransactionalRequest(Sender.java:426)
	at org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:316)
	at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:243)
	at java.base/java.lang.Thread.run(Thread.java:840)
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.
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 125, in loop
    assert totalMessCountTest == totalMessCountTarget, f"Source and target {self.target_topic_path}-{i} topics total messages count are not equal:" + \
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
AssertionError: Source and target target-topic-0 topics total messages count are not equal:{totalMessCountTest} and {totalMessCountTarget} respectively.
contrib/tools/python3/Lib/subprocess.py:1140: ResourceWarning: subprocess 1373030 is still running
ResourceWarning: Enable tracemalloc to get the object allocation traceback
contrib/tools/python3/Lib/subprocess.py:1140: ResourceWarning: subprocess 1373029 is still running
ResourceWarning: Enable tracemalloc to get the object allocation traceback
contrib/tools/python3/Lib/subprocess.py:1140: ResourceWarning: subprocess 1372912 is still running
ResourceWarning: Enable tracemalloc to get the object allocation traceback
contrib/tools/python3/Lib/subprocess.py:1140: ResourceWarning: subprocess 1372911 is still running
ResourceWarning: Enable tracemalloc to get the object allocation traceback
contrib/tools/python3/Lib/subprocess.py:1140: ResourceWarning: subprocess 1372895 is still running
ResourceWarning: Enable tracemalloc to get the object allocation traceback
contrib/tools/python3/Lib/subprocess.py:1140: ResourceWarning: subprocess 1372894 is still running
ResourceWarning: Enable tracemalloc to get the object allocation traceback
