Function mockMetadataFor

admin_test.go:2177–2186

mockMetadataFor builds a MockMetadataResponse with controller and brokers populated. Callers chain .SetLeader as needed.

(t *testing.T, controller *MockBroker, brokers ...*MockBroker)

// mockMetadataFor builds a MockMetadataResponse with controller and brokers
// populated. Callers chain .SetLeader as needed.
func mockMetadataFor(t *testing.T, controller *MockBroker, brokers ...*MockBroker) *MockMetadataResponse {
	t.Helper()
	m := NewMockMetadataResponse(t).
		SetController(controller.BrokerID()).
		SetBroker(controller.Addr(), controller.BrokerID())
	for _, b := range brokers {
		m.SetBroker(b.Addr(), b.BrokerID())
	}
	return m
}

func TestListOffsets(t *testing.T) {
	const topic = "my-topic"