You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by da...@apache.org on 2025/02/11 13:50:51 UTC
(kafka) branch trunk updated: MINOR: Fix log compaction system test (#18857)
This is an automated email from the ASF dual-hosted git repository.
dajac pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 1bebdd9fe84 MINOR: Fix log compaction system test (#18857)
1bebdd9fe84 is described below
commit 1bebdd9fe846dbaf4293e13eb23c9b3052f24247
Author: David Jacot <da...@gmail.com>
AuthorDate: Tue Feb 11 14:50:45 2025 +0100
MINOR: Fix log compaction system test (#18857)
`log.segment.bytes` must be greater or equals to 1MB (KIP-1030).
```
================================================================================
SESSION REPORT (ALL TESTS)
ducktape version: 0.12.0
session_id: 2025-02-10--003
run time: 55.903 seconds
tests run: 1
passed: 1
flaky: 0
failed: 0
ignored: 0
================================================================================
```
Reviewers: Divij Vaidya <di...@amazon.com>
---
tests/kafkatest/tests/tools/log_compaction_test.py | 10 ++--------
1 file changed, 2 insertions(+), 8 deletions(-)
diff --git a/tests/kafkatest/tests/tools/log_compaction_test.py b/tests/kafkatest/tests/tools/log_compaction_test.py
index 96b6d0bedb0..3b6f1ef8d24 100644
--- a/tests/kafkatest/tests/tools/log_compaction_test.py
+++ b/tests/kafkatest/tests/tools/log_compaction_test.py
@@ -20,33 +20,27 @@ from ducktape.tests.test import Test
from ducktape.mark.resource import cluster
from kafkatest.services.kafka import config_property
-from kafkatest.services.zookeeper import ZookeeperService
from kafkatest.services.kafka import KafkaService, quorum
from kafkatest.services.log_compaction_tester import LogCompactionTester
class LogCompactionTest(Test):
# Configure smaller segment size to create more segments for compaction
- LOG_SEGMENT_BYTES = "1024000"
+ LOG_SEGMENT_BYTES = "1048576"
def __init__(self, test_context):
super(LogCompactionTest, self).__init__(test_context)
self.num_zk = 1
self.num_brokers = 1
- self.zk = ZookeeperService(test_context, self.num_zk) if quorum.for_test(test_context) == quorum.zk else None
self.kafka = None
self.compaction_verifier = None
- def setUp(self):
- if self.zk:
- self.zk.start()
-
def start_kafka(self, security_protocol, interbroker_security_protocol):
self.kafka = KafkaService(
self.test_context,
num_nodes = self.num_brokers,
- zk = self.zk,
+ zk = None,
security_protocol=security_protocol,
interbroker_security_protocol=interbroker_security_protocol,
server_prop_overrides=[