MCPcopy
hub / github.com/IBM/sarama / GroupError

Method GroupError

offset_fetch_response.go:378–386  ·  view source on GitHub ↗

GroupError returns the group-level error: for v8+ the error of Groups[0], otherwise the top-level Err.

()

Source from the content-addressed store, hash-verified

376// GroupError returns the group-level error: for v8+ the error of Groups[0],
377// otherwise the top-level Err.
378func (r *OffsetFetchResponse) GroupError() KError {
379 if r.Version >= 8 {
380 if len(r.Groups) == 0 {
381 return ErrNoError
382 }
383 return r.Groups[0].Err
384 }
385 return r.Err
386}
387
388// GetGroup returns the per-group entry for groupID, or nil if absent or on v0-7.
389func (r *OffsetFetchResponse) GetGroup(groupID string) *OffsetFetchResponseGroup {

Calls

no outgoing calls

Tested by 1