Skip to content

Commit

Permalink
MINOR: Fix log compaction system test (#18857)
Browse files Browse the repository at this point in the history
`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 <[email protected]>
  • Loading branch information
dajac authored Feb 11, 2025
1 parent 7e405cc commit 1bebdd9
Showing 1 changed file with 2 additions and 8 deletions.
10 changes: 2 additions & 8 deletions tests/kafkatest/tests/tools/log_compaction_test.py
Original file line number Diff line number Diff line change
Expand Up @@ -20,33 +20,27 @@
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=[
Expand Down

0 comments on commit 1bebdd9

Please sign in to comment.