root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

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 <diviv@amazon.com>
This commit is contained in:
David Jacot 2025-02-11 14:50:45 +01:00 committed by GitHub
parent 7e405ccc65
commit 1bebdd9fe8
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
tests/kafkatest/tests/tools/log_compaction_test.py
View File

@ -20,33 +20,27 @@ from ducktape.tests.test import Test
from ducktape.mark.resource import cluster from ducktape.mark.resource import cluster
from kafkatest.services.kafka import config_property from kafkatest.services.kafka import config_property
from kafkatest.services.zookeeper import ZookeeperService
from kafkatest.services.kafka import KafkaService, quorum from kafkatest.services.kafka import KafkaService, quorum
from kafkatest.services.log_compaction_tester import LogCompactionTester from kafkatest.services.log_compaction_tester import LogCompactionTester
class LogCompactionTest(Test): class LogCompactionTest(Test):
# Configure smaller segment size to create more segments for compaction # Configure smaller segment size to create more segments for compaction
LOG_SEGMENT_BYTES = "1024000" LOG_SEGMENT_BYTES = "1048576"
def __init__(self, test_context): def __init__(self, test_context):
super(LogCompactionTest, self).__init__(test_context) super(LogCompactionTest, self).__init__(test_context)
self.num_zk = 1 self.num_zk = 1
self.num_brokers = 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.kafka = None
self.compaction_verifier = None self.compaction_verifier = None
def setUp(self):
if self.zk:
self.zk.start()
def start_kafka(self, security_protocol, interbroker_security_protocol): def start_kafka(self, security_protocol, interbroker_security_protocol):
self.kafka = KafkaService( self.kafka = KafkaService(
self.test_context, self.test_context,
num_nodes = self.num_brokers, num_nodes = self.num_brokers,
zk = self.zk, zk = None,
security_protocol=security_protocol, security_protocol=security_protocol,
interbroker_security_protocol=interbroker_security_protocol, interbroker_security_protocol=interbroker_security_protocol,
server_prop_overrides=[ server_prop_overrides=[