protocol

package

Go to main page

Versions in this module

v1

v1.1.0

Mar 15, 2026

Changes in this version

+ const OffsetEarliest

+ const OffsetLatest

+ const OffsetMaxTimestamp

type ErrorCode

+ const ErrFencedLeaderEpoch

+ const ErrSchemaValidationFailed

+ const ErrUnknownLeaderEpoch

type GetOffsetRequest

+ Timestamp int64

type GetOffsetResponse

+ LeaderEpoch int64

+ Offset int64

+ Timestamp int64

type ProduceRequest

+ LeaderEpoch int64

type ProduceResponse

+ LeaderEpoch int64

v1.0.1

Nov 22, 2025

Changes in this version

+ const HeaderSize

+ const MaxMessageSize

+ const ProtocolVersion

+ func GetBuffer(size int) []byte

+ func PutBuffer(buf []byte)

+ func WithBuffer(size int, fn func([]byte) error) error

+ func ZeroCopySlice(buf []byte, offset, length int) []byte

+ type AcksLevel int16

+ const AcksAll

+ const AcksNone

+ const AcksOne

+ type BufferPool struct

+ func NewBufferPool() *BufferPool

+ func (p *BufferPool) Get(size int) []byte

+ func (p *BufferPool) GetExact(size int) []byte

+ func (p *BufferPool) Put(buf []byte)

+ type Codec struct

+ func NewCodec() *Codec

+ func (c *Codec) DecodeRequest(r io.Reader) (*Request, error)

+ func (c *Codec) DecodeResponse(r io.Reader) (*Response, error)

+ func (c *Codec) DecodeResponsePayload(resp *Response, reqType RequestType) error

+ func (c *Codec) EncodeRequest(w io.Writer, req *Request) error

+ func (c *Codec) EncodeResponse(w io.Writer, resp *Response) error

+ type CreateTopicRequest struct

+ NumPartitions uint32

+ ReplicationFactor uint16

+ Topic string

+ type CreateTopicResponse struct

+ Created bool

+ ErrorCode ErrorCode

+ Topic string

+ type DeleteTopicRequest struct

+ Topic string

+ type DeleteTopicResponse struct

+ Deleted bool

+ ErrorCode ErrorCode

+ Topic string

+ type ErrorCode uint16

+ const ErrAccountDisabled

+ const ErrAuthenticationFailed

+ const ErrAuthorizationFailed

+ const ErrChecksumMismatch

+ const ErrConcurrentTransactions

+ const ErrCorruptMessage

+ const ErrGroupAuthorizationFailed

+ const ErrIllegalGeneration

+ const ErrInconsistentGroupProtocol

+ const ErrInvalidCommitOffsetSize

+ const ErrInvalidCredentials

+ const ErrInvalidGenerationID

+ const ErrInvalidPartitionList

+ const ErrInvalidProducerEpoch

+ const ErrInvalidProducerIDMapping

+ const ErrInvalidProtocol

+ const ErrInvalidRequest

+ const ErrInvalidSessionTimeout

+ const ErrInvalidTransactionState

+ const ErrInvalidTransactionTimeout

+ const ErrMessageTooLarge

+ const ErrNone

+ const ErrNotCoordinator

+ const ErrOffsetOutOfRange

+ const ErrPartitionNotFound

+ const ErrProducerFenced

+ const ErrRebalanceInProgress

+ const ErrRequestTimeout

+ const ErrStorageError

+ const ErrTopicExists

+ const ErrTopicNotFound

+ const ErrTransactionAborted

+ const ErrTransactionCoordinatorFenced

+ const ErrTransactionCoordinatorNotAvailable

+ const ErrUnknownConsumerGroupID

+ const ErrUnknownMemberID

+ const ErrUnknownRequest

+ func (e ErrorCode) Error() string

+ func (e ErrorCode) String() string

+ type ErrorResponse struct

+ ErrorCode ErrorCode

+ Message string

+ type FetchRequest struct

+ MaxBytes uint32

+ Offset int64

+ PartitionID uint32

+ Topic string

+ type FetchResponse struct

+ HighWaterMark int64

+ Messages []Message

+ PartitionID uint32

+ Topic string

+ type GetOffsetRequest struct

+ PartitionID uint32

+ Topic string

+ type GetOffsetResponse struct

+ EndOffset int64

+ HighWaterMark int64

+ PartitionID uint32

+ StartOffset int64

+ Topic string

+ type HealthCheckRequest struct

+ type HealthCheckResponse struct

+ Status string

+ Uptime int64

+ type ListTopicsRequest struct

+ type ListTopicsResponse struct

+ Topics []TopicInfo

+ type Message struct

+ Headers map[string][]byte

+ Key []byte

+ Offset int64

+ Timestamp int64

+ Value []byte

+ func (m *Message) Size() int

+ type MessageBuffer struct

+ func NewMessageBuffer(pool *BufferPool, initialSize int) *MessageBuffer

+ func (mb *MessageBuffer) Bytes() []byte

+ func (mb *MessageBuffer) Release()

+ func (mb *MessageBuffer) Reset()

+ func (mb *MessageBuffer) Slice(offset, length int) []byte

+ func (mb *MessageBuffer) Write(data []byte)

+ func (mb *MessageBuffer) WriteZeroCopy(data []byte) bool

+ type ProduceRequest struct

+ Acks AcksLevel

+ Messages []Message

+ PartitionID uint32

+ TimeoutMs int32

+ Topic string

+ type ProduceResponse struct

+ BaseOffset int64

+ HighWaterMark int64

+ NumMessages uint32

+ PartitionID uint32

+ Topic string

+ type Request struct

+ Header RequestHeader

+ Payload interface{}

+ type RequestFlags uint16

+ const FlagAsync

+ const FlagBatch

+ const FlagCompressed

+ const FlagIdempotent

+ const FlagNone

+ const FlagRequireAck

+ type RequestHeader struct

+ Flags RequestFlags

+ Length uint32

+ RequestID uint64

+ Type RequestType

+ Version byte

+ type RequestType byte

+ const RequestTypeAddOffsetsToTxn

+ const RequestTypeAddPartitionsToTxn

+ const RequestTypeCreateTopic

+ const RequestTypeDeleteTopic

+ const RequestTypeEndTxn

+ const RequestTypeFetch

+ const RequestTypeGetOffset

+ const RequestTypeHealthCheck

+ const RequestTypeHeartbeat

+ const RequestTypeInitProducerID

+ const RequestTypeJoinGroup

+ const RequestTypeLeaveGroup

+ const RequestTypeListTopics

+ const RequestTypeOffsetCommit

+ const RequestTypeOffsetFetch

+ const RequestTypeProduce

+ const RequestTypeSyncGroup

+ const RequestTypeTxnOffsetCommit

+ func (t RequestType) String() string

+ type Response struct

+ Header ResponseHeader

+ Payload interface{}

+ type ResponseHeader struct

+ ErrorCode ErrorCode

+ Length uint32

+ RequestID uint64

+ Status StatusCode

+ type SharedBufferWrapper struct

+ func NewSharedBuffer(buf []byte) *SharedBufferWrapper

+ func (s *SharedBufferWrapper) Bytes() []byte

+ func (s *SharedBufferWrapper) Len() int

+ func (s *SharedBufferWrapper) Slice(offset, length int) []byte

+ type StatusCode byte

+ const StatusError

+ const StatusOK

+ const StatusPartialSuccess

+ func (s StatusCode) String() string

+ type TopicInfo struct

+ Name string

+ NumPartitions uint32

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL