From 4e901922bb03ef6d385ed83a35ab5961b07e313c Mon Sep 17 00:00:00 2001 From: Lucas Kent Date: Thu, 14 Nov 2024 09:39:36 +1100 Subject: [PATCH] cluster_3_racks_multi_shotover_with_2_shotover_down fix intermittent failures --- shotover-proxy/tests/kafka_int_tests/test_cases.rs | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/shotover-proxy/tests/kafka_int_tests/test_cases.rs b/shotover-proxy/tests/kafka_int_tests/test_cases.rs index 3602b2a7a..b677283d9 100644 --- a/shotover-proxy/tests/kafka_int_tests/test_cases.rs +++ b/shotover-proxy/tests/kafka_int_tests/test_cases.rs @@ -791,6 +791,13 @@ pub async fn produce_consume_partitions1_shotover_nodes_go_down( offset: Some(0), }) .await; + consumer.assert_commit_offsets(HashMap::from([( + TopicPartition { + topic_name: topic_name.to_owned(), + partition: 0, + }, + 1, + )])); // kill shotover node(s) for shotover_node in shotover_nodes_to_kill {