Versions in this module Expand all Collapse all v0 v0.9.0 Mar 20, 2020 v0.0.1 Mar 14, 2020 Changes in this version + const APIVersionsKey + const AddOffsetsToTxnKey + const AddPartitionsToTxnKey + const AlterConfigsKey + const AlterReplicaLogDirsKey + const ControlledShutdownKey + const CreateAclsKey + const CreateDelegationTokenKey + const CreatePartitionsKey + const CreateTopicsKey + const DeleteAclsKey + const DeleteGroupsKey + const DeleteRecordsKey + const DeleteTopicsKey + const DescribeAclsKey + const DescribeConfigsKey + const DescribeDelegationTokenKey + const DescribeGroupsKey + const DescribeLogDirsKey + const EndTxnKey + const ExpireDelegationTokenKey + const FetchKey + const FindCoordinatorKey + const HeartbeatKey + const InitProducerIDKey + const JoinGroupKey + const LeaderAndISRKey + const LeaveGroupKey + const ListGroupsKey + const MetadataKey + const OffsetCommitKey + const OffsetFetchKey + const OffsetForLeaderEpochKey + const OffsetsKey + const ProduceKey + const RenewDelegationTokenKey + const SaslAuthenticateKey + const SaslHandshakeKey + const StopReplicaKey + const SyncGroupKey + const TxnOffsetCommitKey + const UpdateMetadataKey + const WriteTxnMarkersKey + var APIVersions = []APIVersion + var Encoding = binary.BigEndian + var ErrBrokerNotAvailable = Error + var ErrClusterAuthorizationFailed = Error + var ErrConcurrentTransactions = Error + var ErrCoordinatorLoadInProgress = Error + var ErrCoordinatorNotAvailable = Error + var ErrCorruptMessage = Error + var ErrDuplicateSequenceNumber = Error + var ErrGroupAuthorizationFailed = Error + var ErrIllegalGeneration = Error + var ErrIllegalSaslState = Error + var ErrInconsistentGroupProtocol = Error + var ErrInsufficientData = errors.New("kafka: insufficient data to decode packet, more bytes expected") + var ErrInvalidArrayLength = errors.New("kafka: invalid array length") + var ErrInvalidByteSliceLength = errors.New("invalid byteslice length") + var ErrInvalidCommitOffsetSize = Error + var ErrInvalidConfig = Error + var ErrInvalidFetchSize = Error + var ErrInvalidGroupId = Error + var ErrInvalidPartitions = Error + var ErrInvalidProducerEpoch = Error + var ErrInvalidProducerIdMapping = Error + var ErrInvalidReplicaAssignment = Error + var ErrInvalidReplicationFactor = Error + var ErrInvalidRequest = Error + var ErrInvalidRequiredAcks = Error + var ErrInvalidSessionTimeout = Error + var ErrInvalidStringLength = errors.New("kafka: invalid string length") + var ErrInvalidTimestamp = Error + var ErrInvalidTopicException = Error + var ErrInvalidTransactionTimeout = Error + var ErrInvalidTxnState = Error + var ErrLeaderNotAvailable = Error + var ErrMessageTooLarge = Error + var ErrNetworkException = Error + var ErrNone = Error + var ErrNotController = Error + var ErrNotCoordinator = Error + var ErrNotEnoughReplicas = Error + var ErrNotEnoughReplicasAfterAppend = Error + var ErrNotLeaderForPartition = Error + var ErrOffsetMetadataTooLarge = Error + var ErrOffsetOutOfRange = Error + var ErrOperationNotAttempted = Error + var ErrOutOfOrderSequenceNumber = Error + var ErrPolicyViolation = Error + var ErrRebalanceInProgress = Error + var ErrRecordListTooLarge = Error + var ErrReplicaNotAvailable = Error + var ErrRequestTimedOut = Error + var ErrSecurityDisabled = Error + var ErrStaleControllerEpoch = Error + var ErrTopicAlreadyExists = Error + var ErrTopicAuthorizationFailed = Error + var ErrTransactionCoordinatorFenced = Error + var ErrTransactionalIdAuthorizationFailed = Error + var ErrUnknown = Error + var ErrUnknownMemberId = Error + var ErrUnknownTopicOrPartition = Error + var ErrUnsupportedForMessageFormat = Error + var ErrUnsupportedSaslMechanism = Error + var ErrUnsupportedVersion = Error + var Errs = map[int16]Error + func Decode(b []byte, in VersionedDecoder, version int16) error + func Decode0(b []byte, in Decoder) error + func Encode(e Encoder) ([]byte, error) + func ExpectZeroSize(sz int, err error) error + func MakeInt16(b []byte) int16 + func MakeInt32(b []byte) int32 + func MakeInt64(b []byte) int64 + func Read(r io.Reader, data interface{}) error + func Size(v interface{}) int + func Write(w io.Writer, data interface{}) error + type APIVersion struct + APIKey int16 + MaxVersion int16 + MinVersion int16 + type APIVersionsRequest struct + APIVersion int16 + func (c *APIVersionsRequest) Decode(_ PacketDecoder, version int16) error + func (c *APIVersionsRequest) Encode(_ PacketEncoder) error + func (c *APIVersionsRequest) Key() int16 + func (r *APIVersionsRequest) Version() int16 + type APIVersionsResponse struct + APIVersion int16 + APIVersions []APIVersion + ErrorCode int16 + ThrottleTime time.Duration + func (c *APIVersionsResponse) Decode(d PacketDecoder, version int16) error + func (c *APIVersionsResponse) Encode(e PacketEncoder) error + func (r *APIVersionsResponse) Version() int16 + type AbortedTransaction struct + FirstOffset int64 + ProducerID int64 + func (t *AbortedTransaction) Decode(d PacketDecoder, version int16) (err error) + func (t *AbortedTransaction) Encode(e PacketEncoder) (err error) + type AlterConfigResourceResponse struct + ErrorCode int16 + ErrorMessage *string + Name string + Type int8 + type AlterConfigsEntry struct + Name string + Value *string + type AlterConfigsRequest struct + APIVersion int16 + Resources []AlterConfigsResource + ValidateOnly bool + func (r *AlterConfigsRequest) Decode(d PacketDecoder, version int16) (err error) + func (r *AlterConfigsRequest) Encode(e PacketEncoder) (err error) + func (r *AlterConfigsRequest) Key() int16 + func (r *AlterConfigsRequest) Version() int16 + type AlterConfigsResource struct + Entries []AlterConfigsEntry + Name string + Type int8 + type AlterConfigsResponse struct + APIVersion int16 + Resources []AlterConfigResourceResponse + ThrottleTime time.Duration + func (r *AlterConfigsResponse) Decode(d PacketDecoder, version int16) (err error) + func (r *AlterConfigsResponse) Encode(e PacketEncoder) error + func (r *AlterConfigsResponse) Version() int16 + type Body interface + Key func() int16 + Version func() int16 + type Broker struct + Host string + NodeID int32 + Port int32 + type Brokers []*Broker + type ByteDecoder struct + func NewDecoder(b []byte) *ByteDecoder + func (d *ByteDecoder) ArrayLength() (int, error) + func (d *ByteDecoder) Bool() (bool, error) + func (d *ByteDecoder) Bytes() ([]byte, error) + func (d *ByteDecoder) Int16() (int16, error) + func (d *ByteDecoder) Int32() (int32, error) + func (d *ByteDecoder) Int32Array() ([]int32, error) + func (d *ByteDecoder) Int64() (int64, error) + func (d *ByteDecoder) Int64Array() ([]int64, error) + func (d *ByteDecoder) Int8() (int8, error) + func (d *ByteDecoder) NullableString() (*string, error) + func (d *ByteDecoder) Offset() int + func (d *ByteDecoder) Pop() error + func (d *ByteDecoder) Push(pd PushDecoder) error + func (d *ByteDecoder) String() (string, error) + func (d *ByteDecoder) StringArray() ([]string, error) + func (d *ByteDecoder) Varint() (int64, error) + func (d *ByteDecoder) VarintBytes() ([]byte, error) + type ByteEncoder struct + func NewByteEncoder(b []byte) *ByteEncoder + func (b *ByteEncoder) Bytes() []byte + func (e *ByteEncoder) Pop() + func (e *ByteEncoder) Push(pe PushEncoder) + func (e *ByteEncoder) PutArrayLength(in int) error + func (e *ByteEncoder) PutBool(in bool) + func (e *ByteEncoder) PutBytes(in []byte) error + func (e *ByteEncoder) PutInt16(in int16) + func (e *ByteEncoder) PutInt32(in int32) + func (e *ByteEncoder) PutInt32Array(in []int32) error + func (e *ByteEncoder) PutInt64(in int64) + func (e *ByteEncoder) PutInt64Array(in []int64) error + func (e *ByteEncoder) PutInt8(in int8) + func (e *ByteEncoder) PutNullableString(in *string) error + func (e *ByteEncoder) PutRawBytes(in []byte) error + func (e *ByteEncoder) PutString(in string) error + func (e *ByteEncoder) PutStringArray(in []string) error + func (e *ByteEncoder) PutVarint(in int64) + func (e *ByteEncoder) PutVarintBytes(in []byte) error + type CRCField struct + StartOffset int + func (f *CRCField) Check(curOffset int, buf []byte) error + func (f *CRCField) Fill(curOffset int, buf []byte) error + func (f *CRCField) ReserveSize() int + func (f *CRCField) SaveOffset(in int) + type ControlledShutdownRequest struct + APIVersion int16 + func (r *ControlledShutdownRequest) Decode(d PacketDecoder, version int16) (err error) + func (r *ControlledShutdownRequest) Encode(e PacketEncoder) (err error) + func (r *ControlledShutdownRequest) Key() int16 + func (r ControlledShutdownRequest) Version() int16 + type ControlledShutdownResponse struct + APIVersion int16 + func (r *ControlledShutdownResponse) Decode(d PacketDecoder, version int16) (err error) + func (r *ControlledShutdownResponse) Encode(e PacketEncoder) (err error) + func (r *ControlledShutdownResponse) Version() int16 + type Coordinator struct + Host string + NodeID int32 + Port int32 + type CoordinatorType int8 + const CoordinatorGroup + const CoordinatorTransaction + type CreateTopicRequest struct + Configs map[string]*string + NumPartitions int32 + ReplicaAssignment map[int32][]int32 + ReplicationFactor int16 + Topic string + type CreateTopicRequests struct + APIVersion int16 + Requests []*CreateTopicRequest + Timeout time.Duration + ValidateOnly bool + func (r *CreateTopicRequests) Decode(d PacketDecoder, version int16) error + func (r *CreateTopicRequests) Encode(e PacketEncoder) (err error) + func (r *CreateTopicRequests) Key() int16 + func (r *CreateTopicRequests) Version() int16 + type CreateTopicsResponse struct + APIVersion int16 + ThrottleTime time.Duration + TopicErrorCodes []*TopicErrorCode + func (c *CreateTopicsResponse) Decode(d PacketDecoder, version int16) error + func (c *CreateTopicsResponse) Encode(e PacketEncoder) (err error) + func (r *CreateTopicsResponse) Version() int16 + type Data struct + Partition int32 + RecordSet []byte + type Datas []*Data + type Decoder interface + Decode func(d PacketDecoder) error + type DeleteTopicsRequest struct + APIVersion int16 + Timeout time.Duration + Topics []string + func (r *DeleteTopicsRequest) Decode(d PacketDecoder, version int16) (err error) + func (r *DeleteTopicsRequest) Encode(e PacketEncoder) (err error) + func (r *DeleteTopicsRequest) Key() int16 + func (r *DeleteTopicsRequest) Version() int16 + type DeleteTopicsResponse struct + APIVersion int16 + ThrottleTime time.Duration + TopicErrorCodes []*TopicErrorCode + func (c *DeleteTopicsResponse) Decode(d PacketDecoder, version int16) error + func (c *DeleteTopicsResponse) Encode(e PacketEncoder) error + func (r *DeleteTopicsResponse) Version() int16 + type DescribeConfigsEntry struct + IsDefault bool + IsSensitive bool + Name string + ReadOnly bool + Synonyms []DescribeConfigsSynonym + Value *string + type DescribeConfigsRequest struct + APIVersion int16 + IncludeSynonyms bool + Resources []DescribeConfigsResource + func (r *DescribeConfigsRequest) Decode(d PacketDecoder, version int16) (err error) + func (r *DescribeConfigsRequest) Encode(e PacketEncoder) (err error) + func (r *DescribeConfigsRequest) Key() int16 + func (r *DescribeConfigsRequest) Version() int16 + type DescribeConfigsResource struct + ConfigNames []string + Name string + Type int8 + type DescribeConfigsResourceResponse struct + ConfigEntries []DescribeConfigsEntry + ErrorCode int16 + ErrorMessage *string + Name string + Type int8 + type DescribeConfigsResponse struct + APIVersion int16 + Resources []DescribeConfigsResourceResponse + ThrottleTime time.Duration + func (r *DescribeConfigsResponse) Decode(d PacketDecoder, version int16) (err error) + func (r *DescribeConfigsResponse) Encode(e PacketEncoder) error + func (r *DescribeConfigsResponse) Version() int16 + type DescribeConfigsSynonym struct + Name string + Source int8 + Value *string + type DescribeGroupsRequest struct + APIVersion int16 + GroupIDs []string + func (r *DescribeGroupsRequest) Decode(d PacketDecoder, version int16) (err error) + func (r *DescribeGroupsRequest) Encode(e PacketEncoder) error + func (r *DescribeGroupsRequest) Key() int16 + func (r *DescribeGroupsRequest) Version() int16 + type DescribeGroupsResponse struct + APIVersion int16 + Groups []Group + ThrottleTime time.Duration + func (r *DescribeGroupsResponse) Decode(d PacketDecoder, version int16) (err error) + func (r *DescribeGroupsResponse) Encode(e PacketEncoder) error + func (r *DescribeGroupsResponse) Key() int16 + type Encoder interface + Encode func(e PacketEncoder) error + type Error struct + func (e Error) Code() int16 + func (e Error) Error() string + func (e Error) String() string + func (e Error) WithErr(err error) Error + type FetchPartition struct + FetchOffset int64 + MaxBytes int32 + Partition int32 + type FetchPartitionResponse struct + AbortedTransactions []*AbortedTransaction + ErrorCode int16 + HighWatermark int64 + LastStableOffset int64 + Partition int32 + RecordSet []byte + func (r *FetchPartitionResponse) Decode(d PacketDecoder, version int16) (err error) + func (r *FetchPartitionResponse) Encode(e PacketEncoder, version int16) (err error) + type FetchPartitionResponses []*FetchPartitionResponse + type FetchPartitions []*FetchPartition + type FetchRequest struct + APIVersion int16 + IsolationLevel IsolationLevel + MaxBytes int32 + MaxWaitTime time.Duration + MinBytes int32 + ReplicaID int32 + Topics []*FetchTopic + func (r *FetchRequest) Decode(d PacketDecoder, version int16) (err error) + func (r *FetchRequest) Encode(e PacketEncoder) (err error) + func (r *FetchRequest) Key() int16 + func (r *FetchRequest) Version() int16 + type FetchResponse struct + APIVersion int16 + Responses FetchTopicResponses + ThrottleTime time.Duration + func (r *FetchResponse) Decode(d PacketDecoder, version int16) (err error) + func (r *FetchResponse) Encode(e PacketEncoder) (err error) + func (r *FetchResponse) Version() int16 + type FetchTopic struct + Partitions []*FetchPartition + Topic string + type FetchTopicResponse struct + PartitionResponses FetchPartitionResponses + Topic string + type FetchTopicResponses []*FetchTopicResponse + type FetchTopics []*FetchTopic + type FindCoordinatorRequest struct + APIVersion int16 + CoordinatorKey string + CoordinatorType CoordinatorType + func (r *FindCoordinatorRequest) Decode(d PacketDecoder, version int16) (err error) + func (r *FindCoordinatorRequest) Encode(e PacketEncoder) (err error) + func (r *FindCoordinatorRequest) Key() int16 + func (r *FindCoordinatorRequest) Version() int16 + type FindCoordinatorResponse struct + APIVersion int16 + Coordinator Coordinator + ErrorCode int16 + ErrorMessage *string + ThrottleTime time.Duration + func (r *FindCoordinatorResponse) Decode(d PacketDecoder, version int16) (err error) + func (r *FindCoordinatorResponse) Encode(e PacketEncoder) (err error) + func (r *FindCoordinatorResponse) Version() int16 + type Group struct + ErrorCode int16 + GroupID string + GroupMembers map[string]*GroupMember + Protocol string + ProtocolType string + State string + func (r *Group) Decode(d PacketDecoder, version int16) (err error) + func (r *Group) Encode(e PacketEncoder) error + type GroupAssignment struct + MemberAssignment []byte + MemberID string + type GroupMember struct + ClientHost string + ClientID string + GroupMemberAssignment []byte + GroupMemberMetadata []byte + func (r *GroupMember) Decode(d PacketDecoder, version int16) (err error) + func (r *GroupMember) Encode(e PacketEncoder) error + type GroupProtocol struct + ProtocolMetadata []byte + ProtocolName string + type Header struct + HeaderKey int64 + HeaderKeyLength int64 + HeaderValueLength int64 + Value []byte + func (m *Header) Decode(d PacketDecoder) error + func (m *Header) Encode(e PacketEncoder) error + type HeartbeatRequest struct + APIVersion int16 + GroupGenerationID int32 + GroupID string + MemberID string + func (r *HeartbeatRequest) Decode(d PacketDecoder, version int16) (err error) + func (r *HeartbeatRequest) Encode(e PacketEncoder) (err error) + func (r *HeartbeatRequest) Key() int16 + func (r *HeartbeatRequest) Version() int16 + type HeartbeatResponse struct + APIVersion int16 + ErrorCode int16 + ThrottleTime time.Duration + func (r *HeartbeatResponse) Decode(d PacketDecoder, version int16) (err error) + func (r *HeartbeatResponse) Encode(e PacketEncoder) error + func (r *HeartbeatResponse) Key() int16 + func (r *HeartbeatResponse) Version() int16 + type Int32s []int32 + type IsolationLevel int8 + const ReadCommitted + const ReadUncommitted + type JoinGroupRequest struct + APIVersion int16 + GroupID string + GroupProtocols []*GroupProtocol + MemberID string + ProtocolType string + RebalanceTimeout int32 + SessionTimeout int32 + func (r *JoinGroupRequest) Decode(d PacketDecoder, version int16) (err error) + func (r *JoinGroupRequest) Encode(e PacketEncoder) (err error) + func (r *JoinGroupRequest) Key() int16 + func (r *JoinGroupRequest) Version() int16 + type JoinGroupResponse struct + APIVersion int16 + ErrorCode int16 + GenerationID int32 + GroupProtocol string + LeaderID string + MemberID string + Members []Member + ThrottleTime time.Duration + func (r *JoinGroupResponse) Decode(d PacketDecoder, version int16) (err error) + func (r *JoinGroupResponse) Encode(e PacketEncoder) (err error) + func (r *JoinGroupResponse) Key() int16 + func (r *JoinGroupResponse) Version() int16 + type LeaderAndISRPartition struct + ErrorCode int16 + Partition int32 + Topic string + type LeaderAndISRPartitions []*LeaderAndISRPartition + type LeaderAndISRRequest struct + APIVersion int16 + ControllerEpoch int32 + ControllerID int32 + LiveLeaders []*LiveLeader + PartitionStates []*PartitionState + func (r *LeaderAndISRRequest) Decode(d PacketDecoder, version int16) (err error) + func (r *LeaderAndISRRequest) Encode(e PacketEncoder) error + func (r *LeaderAndISRRequest) Key() int16 + func (r *LeaderAndISRRequest) Version() int16 + type LeaderAndISRResponse struct + APIVersion int16 + ErrorCode int16 + Partitions []*LeaderAndISRPartition + func (r *LeaderAndISRResponse) Decode(d PacketDecoder, version int16) (err error) + func (r *LeaderAndISRResponse) Encode(e PacketEncoder) error + func (r *LeaderAndISRResponse) Key() int16 + func (r *LeaderAndISRResponse) Version() int16 + type LeaveGroupRequest struct + APIVersion int16 + GroupID string + MemberID string + func (r *LeaveGroupRequest) Decode(d PacketDecoder, version int16) (err error) + func (r *LeaveGroupRequest) Encode(e PacketEncoder) error + func (r *LeaveGroupRequest) Key() int16 + func (r *LeaveGroupRequest) Version() int16 + type LeaveGroupResponse struct + APIVersion int16 + ErrorCode int16 + ThrottleTime time.Duration + func (r *LeaveGroupResponse) Decode(d PacketDecoder, version int16) (err error) + func (r *LeaveGroupResponse) Encode(e PacketEncoder) error + func (r *LeaveGroupResponse) Key() int16 + func (r *LeaveGroupResponse) Version() int16 + type LenEncoder struct + Length int + func (e *LenEncoder) Pop() + func (e *LenEncoder) Push(pe PushEncoder) + func (e *LenEncoder) PutArrayLength(in int) error + func (e *LenEncoder) PutBool(in bool) + func (e *LenEncoder) PutBytes(in []byte) error + func (e *LenEncoder) PutInt16(in int16) + func (e *LenEncoder) PutInt32(in int32) + func (e *LenEncoder) PutInt32Array(in []int32) error + func (e *LenEncoder) PutInt64(in int64) + func (e *LenEncoder) PutInt64Array(in []int64) error + func (e *LenEncoder) PutInt8(in int8) + func (e *LenEncoder) PutNullableString(in *string) error + func (e *LenEncoder) PutRawBytes(in []byte) error + func (e *LenEncoder) PutString(in string) error + func (e *LenEncoder) PutStringArray(in []string) error + func (e *LenEncoder) PutVarint(in int64) + func (e *LenEncoder) PutVarintBytes(in []byte) error + type ListGroup struct + GroupID string + ProtocolType string + type ListGroupsRequest struct + APIVersion int16 + func (r *ListGroupsRequest) Decode(d PacketDecoder, version int16) (err error) + func (r *ListGroupsRequest) Encode(e PacketEncoder) error + func (r *ListGroupsRequest) Key() int16 + func (r *ListGroupsRequest) Version() int16 + type ListGroupsResponse struct + APIVersion int16 + ErrorCode int16 + Groups []ListGroup + ThrottleTime time.Duration + func (r *ListGroupsResponse) Decode(d PacketDecoder, version int16) (err error) + func (r *ListGroupsResponse) Encode(e PacketEncoder) error + func (r *ListGroupsResponse) Key() int16 + func (r *ListGroupsResponse) Version() int16 + type LiveLeader struct + Host string + ID int32 + Port int32 + type LiveLeaders []*LiveLeader + type Member struct + MemberID string + MemberMetadata []byte + type Message struct + Attributes int8 + Crc int32 + Key []byte + MagicByte int8 + Timestamp time.Time + Value []byte + func (m *Message) Decode(d PacketDecoder) error + func (m *Message) Encode(e PacketEncoder) error + type MessageSet struct + Messages []*Message + Offset int64 + PartialTrailingMessages bool + Size int32 + func (ms *MessageSet) Decode(d PacketDecoder) error + func (ms *MessageSet) Encode(e PacketEncoder) error + type MetadataRequest struct + APIVersion int16 + AllowAutoTopicCreation bool + Topics []string + func (r *MetadataRequest) Decode(d PacketDecoder, version int16) (err error) + func (r *MetadataRequest) Encode(e PacketEncoder) (err error) + func (r *MetadataRequest) Key() int16 + func (r *MetadataRequest) Version() int16 + type MetadataResponse struct + APIVersion int16 + Brokers []*Broker + ControllerID int32 + TopicMetadata []*TopicMetadata + func (r *MetadataResponse) Decode(d PacketDecoder, version int16) (err error) + func (r *MetadataResponse) Encode(e PacketEncoder) (err error) + func (r *MetadataResponse) Version() int16 + type OffsetCommitPartitionRequest struct + Metadata *string + Offset int64 + Partition int32 + Timestamp int64 + type OffsetCommitPartitionResponse struct + ErrorCode int16 + Partition int32 + type OffsetCommitRequest struct + APIVersion int16 + GenerationID int32 + GroupID string + MemberID string + RetentionTime int64 + Topics []OffsetCommitTopicRequest + func (r *OffsetCommitRequest) Decode(d PacketDecoder, version int16) (err error) + func (r *OffsetCommitRequest) Encode(e PacketEncoder) (err error) + func (r *OffsetCommitRequest) Key() int16 + func (r *OffsetCommitRequest) Version() int16 + type OffsetCommitResponse struct + APIVersion int16 + Responses []OffsetCommitTopicResponse + ThrottleTime time.Duration + func (r *OffsetCommitResponse) Decode(d PacketDecoder, version int16) (err error) + func (r *OffsetCommitResponse) Encode(e PacketEncoder) (err error) + type OffsetCommitTopicRequest struct + Partitions []OffsetCommitPartitionRequest + Topic string + type OffsetCommitTopicResponse struct + PartitionResponses []OffsetCommitPartitionResponse + Topic string + type OffsetFetchPartition struct + ErrorCode int16 + Metadata *string + Offset int16 + Partition int32 + type OffsetFetchRequest struct + APIVersion int16 + GroupID string + Topics []OffsetFetchTopicRequest + func (r *OffsetFetchRequest) Decode(d PacketDecoder, version int16) (err error) + func (r *OffsetFetchRequest) Encode(e PacketEncoder) (err error) + func (r *OffsetFetchRequest) Key() int16 + func (r *OffsetFetchRequest) Version() int16 + type OffsetFetchResponse struct + APIVersion int16 + Responses []OffsetFetchTopicResponse + func (r *OffsetFetchResponse) Decode(d PacketDecoder, version int16) (err error) + func (r *OffsetFetchResponse) Encode(e PacketEncoder) (err error) + func (r *OffsetFetchResponse) Version() int16 + type OffsetFetchTopicRequest struct + Partitions []int32 + Topic string + type OffsetFetchTopicResponse struct + Partitions []OffsetFetchPartition + Topic string + type OffsetResponse struct + PartitionResponses []*PartitionResponse + Topic string + type OffsetsPartition struct + MaxNumOffsets int32 + Partition int32 + Timestamp int64 + type OffsetsRequest struct + APIVersion int16 + IsolationLevel int8 + ReplicaID int32 + Topics []*OffsetsTopic + func (r *OffsetsRequest) Decode(d PacketDecoder, version int16) (err error) + func (r *OffsetsRequest) Encode(e PacketEncoder) (err error) + func (r *OffsetsRequest) Key() int16 + func (r *OffsetsRequest) Version() int16 + type OffsetsResponse struct + APIVersion int16 + Responses []*OffsetResponse + ThrottleTime time.Duration + func (r *OffsetsResponse) Decode(d PacketDecoder, version int16) (err error) + func (r *OffsetsResponse) Encode(e PacketEncoder) (err error) + func (r *OffsetsResponse) Version() int16 + type OffsetsTopic struct + Partitions []*OffsetsPartition + Topic string + type PacketDecoder interface + ArrayLength func() (int, error) + Bool func() (bool, error) + Bytes func() ([]byte, error) + Int16 func() (int16, error) + Int32 func() (int32, error) + Int32Array func() ([]int32, error) + Int64 func() (int64, error) + Int64Array func() ([]int64, error) + Int8 func() (int8, error) + NullableString func() (*string, error) + Pop func() error + Push func(pd PushDecoder) error + String func() (string, error) + StringArray func() ([]string, error) + Varint func() (int64, error) + VarintBytes func() ([]byte, error) + type PacketEncoder interface + Pop func() + Push func(pe PushEncoder) + PutArrayLength func(in int) error + PutBool func(in bool) + PutBytes func(in []byte) error + PutInt16 func(in int16) + PutInt32 func(in int32) + PutInt32Array func(in []int32) error + PutInt64 func(in int64) + PutInt64Array func(in []int64) error + PutInt8 func(in int8) + PutNullableString func(in *string) error + PutRawBytes func(in []byte) error + PutString func(in string) error + PutStringArray func(in []string) error + PutVarint func(in int64) + PutVarintBytes func(in []byte) error + type PartitionMetadata struct + ISR []int32 + Leader int32 + PartitionErrorCode int16 + PartitionID int32 + Replicas []int32 + type PartitionMetadatas []*PartitionMetadata + type PartitionResponse struct + ErrorCode int16 + Offset int64 + Offsets []int64 + Partition int32 + Timestamp time.Time + type PartitionState struct + ControllerEpoch int32 + ISR []int32 + IsNew bool + Leader int32 + LeaderEpoch int32 + Partition int32 + Replicas []int32 + Topic string + ZKVersion int32 + type PartitionStates []*PartitionState + type ProducePartitionResponse struct + BaseOffset int64 + ErrorCode int16 + LogAppendTime time.Time + LogStartOffset int64 + Partition int32 + type ProducePartitionResponses []*ProducePartitionResponse + type ProduceRequest struct + APIVersion int16 + Acks int16 + Timeout time.Duration + TopicData []*TopicData + TransactionalID *string + func (r *ProduceRequest) Decode(d PacketDecoder, version int16) (err error) + func (r *ProduceRequest) Encode(e PacketEncoder) (err error) + func (r *ProduceRequest) Key() int16 + func (r *ProduceRequest) Version() int16 + type ProduceResponse struct + APIVersion int16 + Responses []*ProduceTopicResponse + ThrottleTime time.Duration + func (r *ProduceResponse) Decode(d PacketDecoder, version int16) (err error) + func (r *ProduceResponse) Encode(e PacketEncoder) (err error) + type ProduceTopicResponse struct + PartitionResponses []*ProducePartitionResponse + Topic string + type ProduceTopicResponses []*ProduceTopicResponse + type PushDecoder interface + Check func(curOffset int, buf []byte) error + Fill func(curOffset int, buf []byte) error + ReserveSize func() int + SaveOffset func(in int) + type PushEncoder interface + Fill func(curOffset int, buf []byte) error + ReserveSize func() int + SaveOffset func(in int) + type Record struct + Attributes int8 + Headers []*Header + Key []byte + Length int64 + OffsetDelta int64 + TimestampDelta int64 + Value []byte + func (r *Record) Decode(d PacketDecoder) error + func (r *Record) Encode(e PacketEncoder) error + type RecordBatch struct + Attributes int16 + BaseOffset int64 + BaseSequence int32 + BatchLength int32 + FirstTimestamp int64 + LastOffsetDelta int32 + Magic int8 + MaxTimestamp int64 + PartialTrailingMessages bool + PartitionLeaderEpoch int32 + ProducerEpoch int16 + ProducerId int64 + Records []*Record + func (rb *RecordBatch) Decode(d PacketDecoder) error + func (rb *RecordBatch) Encode(e PacketEncoder) error + func (rb *RecordBatch) String() string + type Request struct + Body Body + ClientID string + CorrelationID int32 + func (r *Request) Encode(pe PacketEncoder) (err error) + type RequestHeader struct + APIKey int16 + APIVersion int16 + ClientID string + CorrelationID int32 + Size int32 + func (r *RequestHeader) Decode(d PacketDecoder) error + func (r *RequestHeader) Encode(e PacketEncoder) + func (r *RequestHeader) String() string + type Response struct + Body ResponseBody + CorrelationID int32 + Size int32 + func (r Response) Decode(pd PacketDecoder, version int16) (err error) + func (r Response) Encode(pe PacketEncoder) (err error) + type ResponseBody interface + type SaslHandshakeRequest struct + APIVersion int16 + func (r *SaslHandshakeRequest) Decode(d PacketDecoder, version int16) (err error) + func (r *SaslHandshakeRequest) Encode(e PacketEncoder) (err error) + func (r *SaslHandshakeRequest) Key() int16 + func (r *SaslHandshakeRequest) Version() int16 + type SaslHandshakeResponse struct + func (r *SaslHandshakeResponse) Decode(d PacketDecoder, version int16) (err error) + func (r *SaslHandshakeResponse) Encode(e PacketEncoder) (err error) + type SizeField struct + StartOffset int + func (s *SizeField) Check(curOffset int, buf []byte) error + func (s *SizeField) Fill(curOffset int, buf []byte) error + func (s *SizeField) ReserveSize() int + func (s *SizeField) SaveOffset(in int) + type StopReplicaPartition struct + Partition int32 + Topic string + type StopReplicaRequest struct + APIVersion int16 + ControllerEpoch int32 + ControllerID int32 + DeletePartitions bool + Partitions []*StopReplicaPartition + func (r *StopReplicaRequest) Decode(d PacketDecoder, version int16) (err error) + func (r *StopReplicaRequest) Encode(e PacketEncoder) (err error) + func (r *StopReplicaRequest) Key() int16 + func (r *StopReplicaRequest) Version() int16 + type StopReplicaResponse struct + ErrorCode int16 + Partitions []*StopReplicaResponsePartition + func (r *StopReplicaResponse) Decode(d PacketDecoder, version int16) (err error) + func (r *StopReplicaResponse) Encode(e PacketEncoder) (err error) + type StopReplicaResponsePartition struct + ErrorCode int16 + Partition int32 + Topic string + type Strings []string + type SyncGroupRequest struct + APIVersion int16 + GenerationID int32 + GroupAssignments []GroupAssignment + GroupID string + MemberID string + func (r *SyncGroupRequest) Decode(d PacketDecoder, version int16) (err error) + func (r *SyncGroupRequest) Encode(e PacketEncoder) error + func (r *SyncGroupRequest) Key() int16 + func (r *SyncGroupRequest) Version() int16 + type SyncGroupResponse struct + APIVersion int16 + ErrorCode int16 + MemberAssignment []byte + ThrottleTime time.Duration + func (r *SyncGroupResponse) Decode(d PacketDecoder, version int16) (err error) + func (r *SyncGroupResponse) Encode(e PacketEncoder) error + func (r *SyncGroupResponse) Key() int16 + type TopicData struct + Data []*Data + Topic string + type TopicDatas []*TopicData + type TopicErrorCode struct + ErrorCode int16 + ErrorMessage *string + Topic string + type TopicMetadata struct + PartitionMetadata []*PartitionMetadata + Topic string + TopicErrorCode int16 + type TopicMetadatas []*TopicMetadata + type UpdateMetadataRequest struct + APIVersion int16 + func (r *UpdateMetadataRequest) Decode(d PacketDecoder, version int16) (err error) + func (r *UpdateMetadataRequest) Encode(e PacketEncoder) (err error) + func (r *UpdateMetadataRequest) Key() int16 + func (r *UpdateMetadataRequest) Version() int16 + type UpdateMetadataResponse struct + func (r *UpdateMetadataResponse) Decode(d PacketDecoder, version int16) (err error) + func (r *UpdateMetadataResponse) Encode(e PacketEncoder) (err error) + type VersionedDecoder interface + Decode func(d PacketDecoder, version int16) error