sarama/metadata_request.go

package kafka

type MetadataRequest struct {
	Topics []*string
}

func (mr *MetadataRequest) encode(pe packetEncoder) {
	pe.putArrayCount(len(mr.Topics))
	for i := range mr.Topics {
		pe.putString(mr.Topics[i])
	}
}

func (mr *MetadataRequest) key() int16 {
	return 3
}

func (mr *MetadataRequest) version() int16 {
	return 0
}

func (mr *MetadataRequest) responseDecoder() decoder {
	return new(MetadataResponse)
}