cubefs

1
package sarama
2

3
type SyncGroupResponse struct {
4
	Err              KError
5
	MemberAssignment []byte
6
}
7

8
func (r *SyncGroupResponse) GetMemberAssignment() (*ConsumerGroupMemberAssignment, error) {
9
	assignment := new(ConsumerGroupMemberAssignment)
10
	err := decode(r.MemberAssignment, assignment)
11
	return assignment, err
12
}
13

14
func (r *SyncGroupResponse) encode(pe packetEncoder) error {
15
	pe.putInt16(int16(r.Err))
16
	return pe.putBytes(r.MemberAssignment)
17
}
18

19
func (r *SyncGroupResponse) decode(pd packetDecoder, version int16) (err error) {
20
	kerr, err := pd.getInt16()
21
	if err != nil {
22
		return err
23
	}
24

25
	r.Err = KError(kerr)
26

27
	r.MemberAssignment, err = pd.getBytes()
28
	return
29
}
30

31
func (r *SyncGroupResponse) key() int16 {
32
	return 14
33
}
34

35
func (r *SyncGroupResponse) version() int16 {
36
	return 0
37
}
38

39
func (r *SyncGroupResponse) headerVersion() int16 {
40
	return 0
41
}
42

43
func (r *SyncGroupResponse) requiredVersion() KafkaVersion {
44
	return V0_9_0_0
45
}
46