package sarama type LeaveGroupRequest struct { GroupId string MemberId string } func (r *LeaveGroupRequest) encode(pe packetEncoder) error { if err := pe.putString(r.GroupId); err != nil { return err } if err := pe.putString(r.MemberId); err != nil { return err } return nil } func (r *LeaveGroupRequest) decode(pd packetDecoder, version int16) (err error) { if r.GroupId, err = pd.getString(); err != nil { return } if r.MemberId, err = pd.getString(); err != nil { return } return nil } func (r *LeaveGroupRequest) key() int16 { return 13 } func (r *LeaveGroupRequest) version() int16 { return 0 } func (r *LeaveGroupRequest) headerVersion() int16 { return 1 } func (r *LeaveGroupRequest) requiredVersion() KafkaVersion { return V0_9_0_0 }