hub / github.com/segmentio/kafka-go

github.com/segmentio/kafka-go @v0.4.51 sqlite

2,587 symbols 8,599 edges 269 files 551 documented

Extension points exported contracts — how you extend this code

The Balancer interface provides an abstraction of the message distribution logic used by Writer instances to route messa [8 implem

balancer.go

Message (Interface)

Message is an interface implemented by all request and response types of the kafka protocol. This interface is used mos [79 imple

protocol/protocol.go

RecordReader (Interface)

RecordReader is an interface representing a sequence of records. Record sets are used in both produce and fetch requests [10 imple

protocol/record_batch.go

StateMachine (Interface)

StateMachine implements the SASL challenge/response flow for a single SASL handshake. A StateMachine will be created by [5 implem

sasl/sasl.go

Codec (Interface)

Codec represents a compression codec to encode and decode the messages. See : https://cwiki.apache.org/confluence/displa [5 implem

compress/compress.go

Bytes (Interface)

Bytes is an interface implemented by types that represent immutable sequences of bytes. Bytes values are used to abstra [4 implem

protocol/buffer.go

GroupBalancer (Interface)

GroupBalancer encapsulates the client side rebalancing logic. [3 implementers]

groupbalancer.go

RoundTripper (Interface)

RoundTripper is an interface implemented by types which support interacting with kafka brokers. [3 implementers]

transport.go

Core symbols highest fan-in

Shape

Method 1,162

Function 774

Struct 576

TypeAlias 40

Interface 30

FuncType 5

Dependencies from manifests, versioned

github.com/aws/aws-sdk-gov1.41.3 · 1×

github.com/aws/aws-sdk-go-v2v1.16.12 · 1×

github.com/aws/aws-sdk-go-v2/configv1.17.2 · 1×

github.com/aws/aws-sdk-go-v2/credentialsv1.12.15 · 1×

github.com/davecgh/go-spewv1.1.1 · 1×

github.com/go-stack/stackv1.8.0 · 1×

github.com/google/uuidv1.1.0 · 1×

github.com/klauspost/compressv1.15.9 · 1×

github.com/mongodb/mongo-go-driverv0.3.0 · 1×

github.com/pierrec/lz4/v4v4.1.15 · 1×

github.com/pmezard/go-difflibv1.0.0 · 1×

github.com/segmentio/kafka-gov0.4.34 · 1×

Datastores touched

(mongodb)Database · 1 repos

For agents

$ claude mcp add kafka-go \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact