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) 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 }