From 390fc6be3c4702e2458aa09aba8a7be7ccf8ebd5 Mon Sep 17 00:00:00 2001 From: Lucas Kent Date: Wed, 20 Nov 2024 13:53:43 +1100 Subject: [PATCH] Attempt to fix kafka cluster test intermittent failure --- shotover-proxy/tests/kafka_int_tests/test_cases.rs | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/shotover-proxy/tests/kafka_int_tests/test_cases.rs b/shotover-proxy/tests/kafka_int_tests/test_cases.rs index aad87edcb..b98b9b6c5 100644 --- a/shotover-proxy/tests/kafka_int_tests/test_cases.rs +++ b/shotover-proxy/tests/kafka_int_tests/test_cases.rs @@ -57,6 +57,11 @@ async fn admin_setup(connection_builder: &KafkaConnectionBuilder) { num_partitions: 1, replication_factor: 1, }, + NewTopic { + name: "to_change_partitions", + num_partitions: 1, + replication_factor: 1, + }, NewTopic { name: "multi_topic_consumer_1", num_partitions: 3, @@ -107,7 +112,7 @@ async fn admin_setup(connection_builder: &KafkaConnectionBuilder) { admin .create_partitions(&[NewPartition { - topic_name: "to_delete", + topic_name: "to_change_partitions", new_partition_count: 2, }]) .await;