diff --git a/pkg/kgo/client.go b/pkg/kgo/client.go index 90024b7c..8039aa6d 100644 --- a/pkg/kgo/client.go +++ b/pkg/kgo/client.go @@ -86,7 +86,11 @@ func stddial(ctx context.Context, addr string) (net.Conn, error) { } // NewClient returns a new Kafka client with the given options or an error if -// the options are invalid. +// the options are invalid. Connections to brokers are lazily created only when +// requests are written to them. +// +// NewClient also launches a goroutine which periodically updates the cached +// topic metadata. func NewClient(opts ...Opt) (*Client, error) { cfg := defaultCfg() for _, opt := range opts {