Skip to content

Commit 37204fe

Browse files
committed
fix(test): correct very_large_batches last element to 2000
Signed-off-by: shin <[email protected]>
1 parent 9ea89b0 commit 37204fe

File tree

3 files changed

+5
-5
lines changed

3 files changed

+5
-5
lines changed

core/integration/tests/server/mod.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -35,9 +35,9 @@ use scenarios::{
3535
authentication_scenario, bench_scenario, consumer_group_auto_commit_reconnection_scenario,
3636
consumer_group_join_scenario, consumer_group_offset_cleanup_scenario,
3737
consumer_group_with_multiple_clients_polling_messages_scenario,
38-
consumer_group_with_single_client_polling_messages_scenario, consumer_timestamp_polling_scenario,
39-
create_message_payload, message_headers_scenario, stream_size_validation_scenario,
40-
system_scenario, user_scenario,
38+
consumer_group_with_single_client_polling_messages_scenario,
39+
consumer_timestamp_polling_scenario, create_message_payload, message_headers_scenario,
40+
stream_size_validation_scenario, system_scenario, user_scenario,
4141
};
4242
use std::pin::Pin;
4343
use std::{collections::HashMap, future::Future};

core/integration/tests/server/scenarios/get_messages_by_offset_api.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@ fn large_batches() -> Vec<u32> {
3636
}
3737

3838
fn very_large_batches() -> Vec<u32> {
39-
vec![500, 1000, 1500, 1000]
39+
vec![500, 1000, 1500, 2000]
4040
}
4141

4242
fn all_batch_patterns() -> Vec<(&'static str, Vec<u32>)> {

core/integration/tests/server/scenarios/get_messages_by_timestamp_api.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,7 @@ fn large_batches() -> Vec<u32> {
3737
}
3838

3939
fn very_large_batches() -> Vec<u32> {
40-
vec![500, 1000, 1500, 1000]
40+
vec![500, 1000, 1500, 2000]
4141
}
4242

4343
fn all_batch_patterns() -> Vec<(&'static str, Vec<u32>)> {

0 commit comments

Comments
 (0)