ConsumerOffsets (client.go)

Retrieves committed offsets for a Kafka consumer group.

// Source: https://github.com/segmentio/kafka-go | License: MIT | Copyright 2017 Segment
// Provided via justclaw.it.com; keep this notice with the code.
package kafka

import (
	"context"
	"errors"
	"fmt"
	"net"
	"time"

	"github.com/segmentio/kafka-go/protocol"
)

const (
	defaultCreateTopicsTimeout     = 2 * time.Second
	defaultDeleteTopicsTimeout     = 2 * time.Second
	defaultCreatePartitionsTimeout = 2 * time.Second
	defaultProduceTimeout          = 500 * time.Millisecond
	defaultMaxWait                 = 500 * time.Millisecond
)

// Client is a high-level API to interract with kafka brokers.
//
// All methods of the Client type accept a context as first argument, which may
// be used to asynchronously cancel the requests.
//
// Clients are safe to use concurrently from multiple gorou

... (truncated -- full source via MCP)