From 9a3b11c342b6a1acebf04e02d829137869b9dbd7 Mon Sep 17 00:00:00 2001 From: Ahmed Reza Rafsanzani <31310263+medreza@users.noreply.github.com> Date: Wed, 10 Jan 2024 08:25:13 +0700 Subject: [PATCH] fix(get metadata): avoid always creating new admin client (#69) --- kafka.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/kafka.go b/kafka.go index 6cacc97..378db24 100644 --- a/kafka.go +++ b/kafka.go @@ -1005,8 +1005,9 @@ func (client *KafkaClient) getAdminClient(config *kafka.ConfigMap) (*kafka.Admin if err != nil { return nil, err } + client.adminClient = adminClient - return adminClient, nil + return client.adminClient, nil } func (client *KafkaClient) GetMetadata(topic string, timeout time.Duration) (*Metadata, error) {