protocol

Jul 11, 2021

Changes in this version

+ var TypeBool = &Bool

+ var TypeCompactNullableStr = &CompactNullableStr

+ var TypeCompactStr = &CompactStr

+ var TypeInt16 = &Int16

+ var TypeInt32 = &Int32

+ var TypeNullableStr = &NullableStr

+ var TypeStr = &Str

+ var TypeUuid = &Uuid

+ type Array struct

+ Name string

+ Ty Schema

+ func (f *Array) GetName() string

+ func (f *Array) GetSchema() Schema

+ type CompactArray struct

+ Name string

+ Ty Schema

+ func (f *CompactArray) GetName() string

+ func (f *CompactArray) GetSchema() Schema

+ type CompactNullableArray struct

+ Name string

+ Ty EncoderDecoder

+ func (f *CompactNullableArray) GetName() string

+ type Mfield struct

+ Name string

+ Ty Schema

+ func (f *Mfield) GetName() string

+ func (f *Mfield) GetSchema() Schema

+ type SchemaTaggedFields struct

+ Name string

+ func (f SchemaTaggedFields) GetName() string

+ func (f SchemaTaggedFields) GetSchema() Schema

type Struct

+ Schema Schema

+ Values []interface{}

+ type Uuid struct

+ func (f *Uuid) GetFields() []boundField

+ func (f *Uuid) GetFieldsByName() map[string]*boundField

+ func (f *Uuid) GetName() string

Jul 14, 2020

Changes in this version

+ type RequestAcksReader struct

+ func (r RequestAcksReader) ReadAndDiscardHeaderV1Part(reader io.Reader) (err error)

+ func (r RequestAcksReader) ReadAndDiscardProduceAcks(reader io.Reader) (acks int16, err error)

+ func (r RequestAcksReader) ReadAndDiscardProduceTxnAcks(reader io.Reader) (acks int16, err error)

Jun 29, 2020

Changes in this version

type Bool

+ func (f *Bool) GetFields() []boundField

+ func (f *Bool) GetFieldsByName() map[string]*boundField

+ func (f *Bool) GetName() string

type CompactNullableStr

+ func (f *CompactNullableStr) GetFields() []boundField

+ func (f *CompactNullableStr) GetFieldsByName() map[string]*boundField

+ func (f *CompactNullableStr) GetName() string

type CompactStr

+ func (f *CompactStr) GetFields() []boundField

+ func (f *CompactStr) GetFieldsByName() map[string]*boundField

+ func (f *CompactStr) GetName() string

type Field

+ GetSchema func() Schema

type Int16

+ func (f *Int16) GetFields() []boundField

+ func (f *Int16) GetFieldsByName() map[string]*boundField

+ func (f *Int16) GetName() string

type Int32

+ func (f *Int32) GetFields() []boundField

+ func (f *Int32) GetFieldsByName() map[string]*boundField

+ func (f *Int32) GetName() string

type NullableStr

+ func (f *NullableStr) GetFields() []boundField

+ func (f *NullableStr) GetFieldsByName() map[string]*boundField

+ func (f *NullableStr) GetName() string

+ type RequestV2 struct

+ Body ProtocolBody

+ ClientID string

+ CorrelationID int32

+ TaggedFields TaggedFields

+ type ResponseHeaderV1 struct

+ CorrelationID int32

+ Length int32

+ RawTaggedFields []rawTaggedField

+ type SaslAuthenticateRequestV1 struct

+ SaslAuthBytes []byte

+ type SaslAuthenticateRequestV2 struct

+ SaslAuthBytes []byte

+ TaggedFields TaggedFields

+ type SaslAuthenticateResponseV1 struct

+ Err KError

+ ErrMsg *string

+ SaslAuthBytes []byte

+ SessionLifetimeMs int64

+ type SaslAuthenticateResponseV2 struct

+ Err KError

+ ErrMsg *string

+ SaslAuthBytes []byte

+ SessionLifetimeMs int64

+ TaggedFields TaggedFields

type Schema

+ GetFields func() []boundField

+ GetFieldsByName func() map[string]*boundField

+ GetName func() string

type Str

+ func (f *Str) GetFields() []boundField

+ func (f *Str) GetFieldsByName() map[string]*boundField

+ func (f *Str) GetName() string

type Struct

+ func (s *Struct) GetSchema() Schema

+ type TaggedFields struct

Mar 22, 2020

Changes in this version

+ type ByteReader struct

+ func (r ByteReader) ReadByte() (byte, error)

+ type CompactNullableStr struct

+ type CompactStr struct

type RequestKeyVersion

+ func (r *RequestKeyVersion) ResponseHeaderVersion() int16

+ type ResponseHeaderTaggedFields struct

+ func NewResponseHeaderTaggedFields(req *RequestKeyVersion) (*ResponseHeaderTaggedFields, error)

+ func (r *ResponseHeaderTaggedFields) MaybeRead(reader io.Reader) ([]byte, error)

May 11, 2018

Changes in this version

+ type SaslAuthenticateRequestV0 struct

+ SaslAuthBytes []byte

+ type SaslAuthenticateResponseV0 struct

+ Err KError

+ ErrMsg *string

+ SaslAuthBytes []byte

+ type SaslHandshakeRequestV0orV1 struct

+ Mechanism string

+ Version int16

+ type SaslHandshakeResponseV0orV1 struct

+ EnabledMechanisms []string

+ Err KError

Mar 2, 2018

Changes in this version

+ var ErrInsufficientData = errors.New("kafka: insufficient data to decode packet, more bytes expected")

+ var MaxRequestSize int32 = 100 * 1024 * 1024

+ var MaxResponseSize int32 = 100 * 1024 * 1024

+ func Decode(buf []byte, in decoder) error

+ func Encode(e encoder) ([]byte, error)

+ func EncodeSchema(s *Struct, schema Schema) ([]byte, error)

+ type Bool struct

+ type EncoderDecoder interface

+ type Field interface

+ GetName func() string

+ type Int16 struct

+ type Int32 struct

+ type KError int16

+ const ErrBrokerNotAvailable

+ const ErrClusterAuthorizationFailed

+ const ErrConcurrentTransactions

+ const ErrConsumerCoordinatorNotAvailable

+ const ErrDuplicateSequenceNumber

+ const ErrGroupAuthorizationFailed

+ const ErrIllegalGeneration

+ const ErrIllegalSASLState

+ const ErrInconsistentGroupProtocol

+ const ErrInvalidCommitOffsetSize

+ const ErrInvalidConfig

+ const ErrInvalidGroupId

+ const ErrInvalidMessage

+ const ErrInvalidMessageSize

+ const ErrInvalidPartitions

+ const ErrInvalidProducerEpoch

+ const ErrInvalidProducerIDMapping

+ const ErrInvalidReplicaAssignment

+ const ErrInvalidReplicationFactor

+ const ErrInvalidRequest

+ const ErrInvalidRequiredAcks

+ const ErrInvalidSessionTimeout

+ const ErrInvalidTimestamp

+ const ErrInvalidTopic

+ const ErrInvalidTransactionTimeout

+ const ErrInvalidTxnState

+ const ErrKafkaStorageError

+ const ErrLeaderNotAvailable

+ const ErrLogDirNotFound

+ const ErrMessageSetSizeTooLarge

+ const ErrMessageSizeTooLarge

+ const ErrNetworkException

+ const ErrNoError

+ const ErrNotController

+ const ErrNotCoordinatorForConsumer

+ const ErrNotEnoughReplicas

+ const ErrNotEnoughReplicasAfterAppend

+ const ErrNotLeaderForPartition

+ const ErrOffsetMetadataTooLarge

+ const ErrOffsetOutOfRange

+ const ErrOffsetsLoadInProgress

+ const ErrOperationNotAttempted

+ const ErrOutOfOrderSequenceNumber

+ const ErrPolicyViolation

+ const ErrReassignmentInProgress

+ const ErrRebalanceInProgress

+ const ErrReplicaNotAvailable

+ const ErrRequestTimedOut

+ const ErrSASLAuthenticationFailed

+ const ErrSecurityDisabled

+ const ErrStaleControllerEpochCode

+ const ErrTopicAlreadyExists

+ const ErrTopicAuthorizationFailed

+ const ErrTransactionCoordinatorFenced

+ const ErrTransactionalIDAuthorizationFailed

+ const ErrUnknown

+ const ErrUnknownMemberId

+ const ErrUnknownProducerID

+ const ErrUnknownTopicOrPartition

+ const ErrUnsupportedForMessageFormat

+ const ErrUnsupportedSASLMechanism

+ const ErrUnsupportedVersion

+ func (err KError) Error() string

+ type NullableStr struct

+ type PacketDecodingError struct

+ Info string

+ func (err PacketDecodingError) Error() string

+ type PacketEncodingError struct

+ Info string

+ func (err PacketEncodingError) Error() string

+ type ProtocolBody interface

+ type Request struct

+ Body ProtocolBody

+ ClientID string

+ CorrelationID int32

+ type RequestKeyVersion struct

+ ApiKey int16

+ ApiVersion int16

+ Length int32

+ type ResponseHeader struct

+ CorrelationID int32

+ Length int32

+ type ResponseModifier interface

+ Apply func(resp []byte) ([]byte, error)

+ func GetResponseModifier(apiKey int16, apiVersion int16, ...) (ResponseModifier, error)

+ type SaslHandshakeRequestV0 struct

+ Mechanism string

+ type SaslHandshakeResponseV0 struct

+ EnabledMechanisms []string

+ Err KError

+ type Schema interface

+ func NewSchema(name string, fs ...Field) Schema

+ type SchemaDecodingError struct

+ Info string

+ func (err SchemaDecodingError) Error() string

+ type SchemaEncodingError struct

+ Info string

+ func (err SchemaEncodingError) Error() string

+ type Str struct

+ type Struct struct

+ func DecodeSchema(buf []byte, schema Schema) (*Struct, error)

+ func (s *Struct) Replace(name string, value interface{}) error

+ func (s Struct) Get(name string) interface{}

+ func (s Struct) String() string