Method grabClusterConn

transport.go:667–669

grabClusterConn returns the connection to the kafka cluster that the pool is configured to connect to. The transport uses a shared `control` connection to the cluster for any requests that aren't supposed to be sent to specific brokers (e.g. Fetch or Produce requests). Requests intended to be route

(ctx context.Context)

// In either cases, the requests are multiplexed so we can keep a minimal number
// of connections open (N+1, where N is the number of brokers in the cluster).
func (p *connPool) grabClusterConn(ctx context.Context) (*conn, error) {
	return p.ctrl.grabConnOrConnect(ctx)
}

func (p *connPool) sendRequest(ctx context.Context, req Request, state connPoolState) promise {
	brokerID := int32(-1)