Browse Source

Add missing broker Open() call

Dominic Evans 7 years ago
parent
commit
014bdc85aa
1 changed files with 1 additions and 0 deletions
  1. 1 0
      admin.go

+ 1 - 0
admin.go

@@ -176,6 +176,7 @@ func (ca *clusterAdmin) ListTopics() (map[string]TopicDetail, error) {
 	if err != nil {
 		return nil, err
 	}
+	b.Open(ca.client.Config())
 
 	metadataReq := &MetadataRequest{}
 	metadataResp, err := b.GetMetadata(metadataReq)