sarama/consumer_metadata_response.go

package sarama

type ConsumerMetadataResponse struct {
	Err             KError
	CoordinatorId   int32
	CoordinatorHost string
	CoordinatorPort int32
}

func (r *ConsumerMetadataResponse) decode(pd packetDecoder) (err error) {
	tmp, err := pd.getInt16()
	if err != nil {
		return err
	}
	r.Err = KError(tmp)

	if r.Err == NoError {
		r.CoordinatorId, err = pd.getInt32()
		if err != nil {
			return err
		}

		r.CoordinatorHost, err = pd.getString()
		if err != nil {
			return err
		}

		r.CoordinatorPort, err = pd.getInt32()
		if err != nil {
			return err
		}
	}

	return nil
}