diff --git a/tests/kafkatest/tests/inkless/consolidation_dependency_outage_test.py b/tests/kafkatest/tests/inkless/consolidation_dependency_outage_test.py index 6222202076f..b66ee812658 100644 --- a/tests/kafkatest/tests/inkless/consolidation_dependency_outage_test.py +++ b/tests/kafkatest/tests/inkless/consolidation_dependency_outage_test.py @@ -91,7 +91,7 @@ def test_dependency_outage_during_produce(self, metadata_quorum, dependency): "diskless.enable": "true", "remote.storage.enable": "true", "min.insync.replicas": 2, - "segment.bytes": 1048576, + "segment.bytes": 2097152, "segment.ms": 5000, "local.retention.ms": 5000, }, diff --git a/tests/kafkatest/tests/inkless/consolidation_pipeline_test.py b/tests/kafkatest/tests/inkless/consolidation_pipeline_test.py index 9de9ddb54f3..3115da252a3 100644 --- a/tests/kafkatest/tests/inkless/consolidation_pipeline_test.py +++ b/tests/kafkatest/tests/inkless/consolidation_pipeline_test.py @@ -75,8 +75,7 @@ def test_consolidation_pipeline(self, metadata_quorum): "diskless.enable": "true", "remote.storage.enable": "true", "min.insync.replicas": 2, - # Roll segments by size/time so they close and get tiered. - "segment.bytes": 1048576, + "segment.bytes": 2097152, "segment.ms": 5000, }, }, diff --git a/tests/kafkatest/tests/inkless/consolidation_read_from_remote_after_prune_test.py b/tests/kafkatest/tests/inkless/consolidation_read_from_remote_after_prune_test.py index b46b5a23b5d..724b6c51b09 100644 --- a/tests/kafkatest/tests/inkless/consolidation_read_from_remote_after_prune_test.py +++ b/tests/kafkatest/tests/inkless/consolidation_read_from_remote_after_prune_test.py @@ -75,8 +75,7 @@ def test_read_from_remote_after_prune(self, metadata_quorum): "diskless.enable": "true", "remote.storage.enable": "true", "min.insync.replicas": 2, - # Roll segments by size/time so they close and get tiered. - "segment.bytes": 1048576, + "segment.bytes": 2097152, "segment.ms": 5000, # Evict local segments soon after upload so data lives in # remote before the wipe. diff --git a/tests/kafkatest/tests/inkless/consolidation_retention_across_tiers_test.py b/tests/kafkatest/tests/inkless/consolidation_retention_across_tiers_test.py index 80bdd6a4deb..e12713f65c0 100644 --- a/tests/kafkatest/tests/inkless/consolidation_retention_across_tiers_test.py +++ b/tests/kafkatest/tests/inkless/consolidation_retention_across_tiers_test.py @@ -131,8 +131,7 @@ def _start_cluster(self): "diskless.enable": "true", "remote.storage.enable": "true", "min.insync.replicas": 2, - # Roll segments by size/time so they close and get tiered. - "segment.bytes": 1048576, + "segment.bytes": 2097152, "segment.ms": 5000, # Evict local segments soon after upload so the early prefix # lives only in remote -- retention must then reclaim remote. diff --git a/tests/kafkatest/tests/inkless/inkless_topic_switch_test.py b/tests/kafkatest/tests/inkless/inkless_topic_switch_test.py index ef8dfc19b3f..104ee7c950d 100644 --- a/tests/kafkatest/tests/inkless/inkless_topic_switch_test.py +++ b/tests/kafkatest/tests/inkless/inkless_topic_switch_test.py @@ -284,8 +284,7 @@ def _create_classic_tiered_topic(self, topic, num_partitions=1): "configs": { "remote.storage.enable": "true", "min.insync.replicas": 1, - # 1 MiB is the enforced minimum for segment.bytes. - "segment.bytes": 1048576, + "segment.bytes": 2097152, # Force a roll every 2s regardless of segment fill, so that # produced records flow through closed segments quickly. "segment.ms": 2000,