From 92506280b80adebc9e7b733c74e957b9f554bf6c Mon Sep 17 00:00:00 2001 From: Vincent Bernat Date: Mon, 7 Aug 2023 15:34:43 +0200 Subject: [PATCH] orchestrator/kafka: make test more reliable by refreshing metadata --- orchestrator/kafka/functional_test.go | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/orchestrator/kafka/functional_test.go b/orchestrator/kafka/functional_test.go index 861e2348..657e0fe5 100644 --- a/orchestrator/kafka/functional_test.go +++ b/orchestrator/kafka/functional_test.go @@ -71,6 +71,9 @@ func TestTopicCreation(t *testing.T) { } helpers.StartStop(t, c) + if err := client.RefreshMetadata(); err != nil { + t.Fatalf("RefreshMetadata() error:\n%+v", err) + } adminClient, err := sarama.NewClusterAdminFromClient(client) if err != nil { t.Fatalf("NewClusterAdmin() error:\n%+v", err) @@ -113,6 +116,9 @@ func TestTopicMorePartitions(t *testing.T) { } helpers.StartStop(t, c) + if err := client.RefreshMetadata(); err != nil { + t.Fatalf("RefreshMetadata() error:\n%+v", err) + } adminClient, err := sarama.NewClusterAdminFromClient(client) if err != nil { t.Fatalf("NewClusterAdmin() error:\n%+v", err) @@ -138,6 +144,9 @@ func TestTopicMorePartitions(t *testing.T) { } helpers.StartStop(t, c) + if err := client.RefreshMetadata(); err != nil { + t.Fatalf("RefreshMetadata() error:\n%+v", err) + } topics, err = adminClient.ListTopics() if err != nil { t.Fatalf("ListTopics() error:\n%+v", err)