johanels/akvorado
1
0
Fork 0
mirror of https://github.com/akvorado/akvorado.git synced 2025-12-12 06:24:10 +01:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

orchestrator/kafka: make test more reliable by refreshing metadata

Browse Source
This commit is contained in:
Vincent Bernat
2023-08-07 15:34:43 +02:00
parent f8bc565abf
commit 92506280b8
1 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
orchestrator/kafka/functional_test.go
View File

@@ -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)