From 9532a7f3aecaa7261ea6b90046adbedc4d63d682 Mon Sep 17 00:00:00 2001 From: Viktor Somogyi-Vass Date: Thu, 30 Jul 2026 14:57:02 +0200 Subject: [PATCH] test(inkless:consolidation): raise system-test segment.bytes to 2 MiB Consolidation fetch requests segment.bytes minus max.message.bytes so one extra batch still fits the follower segment. Default max.message.bytes is 1048588 (1 MiB plus record overhead), so the old 1 MiB setting left a 1-byte fetch and starved the fetcher. 2 MiB leaves about 1 MiB of fetch budget. segment.ms still rolls on time. --- .../tests/inkless/consolidation_dependency_outage_test.py | 2 +- tests/kafkatest/tests/inkless/consolidation_pipeline_test.py | 3 +-- .../inkless/consolidation_read_from_remote_after_prune_test.py | 3 +-- .../tests/inkless/consolidation_retention_across_tiers_test.py | 3 +-- tests/kafkatest/tests/inkless/inkless_topic_switch_test.py | 3 +-- 5 files changed, 5 insertions(+), 9 deletions(-) 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,