(topic string, partition int32, kerror KError)
| 13 | } |
| 14 | |
| 15 | func (r *OffsetCommitResponse) AddError(topic string, partition int32, kerror KError) { |
| 16 | if r.Errors == nil { |
| 17 | r.Errors = make(map[string]map[int32]KError) |
| 18 | } |
| 19 | partitions := r.Errors[topic] |
| 20 | if partitions == nil { |
| 21 | partitions = make(map[int32]KError) |
| 22 | r.Errors[topic] = partitions |
| 23 | } |
| 24 | partitions[partition] = kerror |
| 25 | } |
| 26 | |
| 27 | func (r *OffsetCommitResponse) encode(pe packetEncoder) error { |
| 28 | if r.Version >= 3 { |
no outgoing calls