diff --git a/kafka/lazy_client.go b/kafka/lazy_client.go index a528c90d..e461d1aa 100644 --- a/kafka/lazy_client.go +++ b/kafka/lazy_client.go @@ -179,6 +179,10 @@ func (c *LazyClient) UpsertUserScramCredential(userScramCredential UserScramCred } func (c *LazyClient) DescribeUserScramCredential(username string, mechanism string) (*UserScramCredential, error) { + err := c.init() + if err != nil { + return err + } return c.inner.DescribeUserScramCredential(username, mechanism) }