Struct stubLeaderClient

async_producer_test.go:2086–2089

}

type stubLeaderClient struct {
	cfg    *Config
	leader *Broker
}

func (c *stubLeaderClient) Config() *Config                            { return c.cfg }
func (c *stubLeaderClient) Controller() (*Broker, error)               { return nil, nil }