Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

kafka

package

Go to main page

Versions in this module

v0

v0.7.0

Apr 2, 2023

v0.6.3

Feb 5, 2023

v0.6.2

Feb 5, 2023

v0.6.1

Feb 1, 2023

v0.6.0

Jan 10, 2023

v0.5.1

Jan 8, 2023

v0.5.0

Dec 29, 2022

v0.4.0

Dec 26, 2022

v0.3.0

Dec 26, 2022

v0.2.0

Dec 24, 2022

v0.1.9

Dec 21, 2022

v0.1.8

Dec 21, 2022

v0.1.7

Dec 20, 2022

v0.1.6

Dec 20, 2022

v0.1.5

Dec 9, 2022

v0.1.4

Dec 2, 2022

v0.1.3

Nov 30, 2022

v0.1.2

Nov 30, 2022

Changes in this version

+ var Dissector dissecting

+ func NewDissector() api.Dissector

+ func ReadResponse(r io.Reader, capture api.Capture, tcpID *api.TcpID, ...) (err error)

+ type AbortedTransactionsV4 struct

+ FirstOffset int32

+ ProducerId int32

+ type ApiKey int16

+ const AddOffsetsToTxn

+ const AddPartitionsToTxn

+ const AlterClientQuotas

+ const AlterConfigs

+ const AlterPartitionReassignments

+ const AlterReplicaLogDirs

+ const ApiVersions

+ const ControlledShutdown

+ const CreateAcls

+ const CreateDelegationToken

+ const CreatePartitions

+ const CreateTopics

+ const DeleteAcls

+ const DeleteGroups

+ const DeleteRecords

+ const DeleteTopics

+ const DescribeAcls

+ const DescribeClientQuotas

+ const DescribeConfigs

+ const DescribeDelegationToken

+ const DescribeGroups

+ const DescribeLogDirs

+ const ElectLeaders

+ const EndTxn

+ const ExpireDelegationToken

+ const Fetch

+ const FindCoordinator

+ const Heartbeat

+ const IncrementalAlterConfigs

+ const InitProducerId

+ const JoinGroup

+ const LeaderAndIsr

+ const LeaveGroup

+ const ListGroups

+ const ListOffsets

+ const ListPartitionReassignments

+ const Metadata

+ const OffsetCommit

+ const OffsetDelete

+ const OffsetFetch

+ const OffsetForLeaderEpoch

+ const Produce

+ const RenewDelegationToken

+ const SaslAuthenticate

+ const SaslHandshake

+ const StopReplica

+ const SyncGroup

+ const TxnOffsetCommit

+ const UpdateMetadata

+ const WriteTxnMarkers

+ func ReadRequest(r io.Reader, tcpID *api.TcpID, counterPair *api.CounterPair, ...) (apiKey ApiKey, apiVersion int16, err error)

+ func (k ApiKey) String() string

+ type ApiVersionsRequestV0 struct

+ type ApiVersionsRequestV3 struct

+ ClientSoftwareName string

+ ClientSoftwareVersion string

+ type ApiVersionsResponseApiKey struct

+ ApiKey int16

+ MaxVersion int16

+ MinVersion int16

+ type ApiVersionsResponseV0 struct

+ ApiKeys []ApiVersionsResponseApiKey

+ ErrorCode int16

+ type ApiVersionsResponseV1 struct

+ ApiKeys []ApiVersionsResponseApiKey

+ ErrorCode int16

+ ThrottleTimeMs int32

+ type AssignmentsV0 struct

+ BrokerIds []int32

+ PartitionIndex int32

+ type Broker struct

+ Host string

+ ID int32

+ Port int32

+ Rack string

+ type BrokerV0 struct

+ Host string

+ NodeId int32

+ Port int32

+ type BrokerV1 struct

+ Host string

+ NodeId int32

+ Port int32

+ Rack string

+ type Compression = compress.Compression

+ type CompressionCodec = compress.Codec

+ type CreateTopicsRequestConfigsV0 struct

+ Name string

+ Value string

+ type CreateTopicsRequestTopicV0 struct

+ Assignments []AssignmentsV0

+ Configs []CreateTopicsRequestConfigsV0

+ Name string

+ NumPartitions int32

+ ReplicationFactor int16

+ type CreateTopicsRequestV0 struct

+ TimeoutMs int32

+ Topics []CreateTopicsRequestTopicV0

+ type CreateTopicsRequestV1 struct

+ TimeoutMs int32

+ Topics []CreateTopicsRequestTopicV0

+ ValidateOnly bool

+ type CreateTopicsResponseConfigsV5 struct

+ ConfigSource int8

+ IsSensitive bool

+ Name string

+ ReadOnly bool

+ Value string

+ type CreateTopicsResponseTopicV0 struct

+ ErrorCode int16

+ Name string

+ type CreateTopicsResponseTopicV1 struct

+ ErrorCode int16

+ ErrorMessage string

+ Name string

+ type CreateTopicsResponseTopicV5 struct

+ Configs []CreateTopicsResponseConfigsV5

+ ErrorCode int16

+ ErrorMessage string

+ Name string

+ NumPartitions int32

+ ReplicationFactor int16

+ type CreateTopicsResponseTopicV7 struct

+ Configs []CreateTopicsResponseConfigsV5

+ ErrorCode int16

+ ErrorMessage string

+ Name string

+ NumPartitions int32

+ ReplicationFactor int16

+ TopicID UUID

+ type CreateTopicsResponseV0 struct

+ Topics []CreateTopicsResponseTopicV0

+ type CreateTopicsResponseV1 struct

+ Topics []CreateTopicsResponseTopicV1

+ type CreateTopicsResponseV2 struct

+ ThrottleTimeMs int32

+ Topics []CreateTopicsResponseTopicV1

+ type CreateTopicsResponseV5 struct

+ ThrottleTimeMs int32

+ Topics []CreateTopicsResponseTopicV5

+ type CreateTopicsResponseV7 struct

+ ThrottleTimeMs int32

+ Topics []CreateTopicsResponseTopicV7

+ type DeleteTopicsReponseResponseV0 struct

+ ErrorCode int16

+ Name string

+ type DeleteTopicsReponseResponseV5 struct

+ ErrorCode int16

+ ErrorMessage string

+ Name string

+ type DeleteTopicsReponseResponseV6 struct

+ ErrorCode int16

+ ErrorMessage string

+ Name string

+ TopicID UUID

+ type DeleteTopicsReponseV0 struct

+ Responses []DeleteTopicsReponseResponseV0

+ type DeleteTopicsReponseV1 struct

+ Responses []DeleteTopicsReponseResponseV0

+ ThrottleTimeMs int32

+ type DeleteTopicsReponseV5 struct

+ Responses []DeleteTopicsReponseResponseV5

+ ThrottleTimeMs int32

+ type DeleteTopicsReponseV6 struct

+ Responses []DeleteTopicsReponseResponseV6

+ ThrottleTimeMs int32

+ type DeleteTopicsRequestTopicV6 struct

+ Name string

+ UUID UUID

+ type DeleteTopicsRequestV0 struct

+ TimeoutMs int32

+ TopicNames []string

+ type DeleteTopicsRequestV6 struct

+ TimeoutMs int32

+ Topics []DeleteTopicsRequestTopicV6

+ type FetchPartitionV0 struct

+ FetchOffset int64

+ Partition int32

+ PartitionMaxBytes int32

+ type FetchPartitionV5 struct

+ FetchOffset int64

+ LogStartOffset int64

+ Partition int32

+ PartitionMaxBytes int32

+ type FetchPartitionV9 struct

+ CurrentLeaderEpoch int32

+ FetchOffset int64

+ LogStartOffset int64

+ Partition int32

+ PartitionMaxBytes int32

+ type FetchRequestV0 struct

+ MaxWaitMs int32

+ MinBytes int32

+ ReplicaId int32

+ Topics []FetchTopicV0

+ type FetchRequestV11 struct

+ ForgottenTopicsData ForgottenTopicsDataV7

+ IsolationLevel int8

+ MaxBytes int32

+ MaxWaitMs int32

+ MinBytes int32

+ RackId string

+ ReplicaId int32

+ SessionEpoch int32

+ SessionId int32

+ Topics []FetchTopicV9

+ type FetchRequestV3 struct

+ MaxBytes int32

+ MaxWaitMs int32

+ MinBytes int32

+ ReplicaId int32

+ Topics []FetchTopicV0

+ type FetchRequestV4 struct

+ IsolationLevel int8

+ MaxBytes int32

+ MaxWaitMs int32

+ MinBytes int32

+ ReplicaId int32

+ Topics []FetchTopicV0

+ type FetchRequestV5 struct

+ IsolationLevel int8

+ MaxBytes int32

+ MaxWaitMs int32

+ MinBytes int32

+ ReplicaId int32

+ Topics []FetchTopicV5

+ type FetchRequestV7 struct

+ ForgottenTopicsData ForgottenTopicsDataV7

+ IsolationLevel int8

+ MaxBytes int32

+ MaxWaitMs int32

+ MinBytes int32

+ ReplicaId int32

+ SessionEpoch int32

+ SessionId int32

+ Topics []FetchTopicV5

+ type FetchRequestV9 struct

+ ForgottenTopicsData ForgottenTopicsDataV7

+ IsolationLevel int8

+ MaxBytes int32

+ MaxWaitMs int32

+ MinBytes int32

+ ReplicaId int32

+ SessionEpoch int32

+ SessionId int32

+ Topics []FetchTopicV9

+ type FetchResponseV0 struct

+ Responses []ResponseFetchV0

+ type FetchResponseV1 struct

+ Responses []ResponseFetchV0

+ ThrottleTimeMs int32

+ type FetchResponseV11 struct

+ ErrorCode int16

+ Responses []ResponseFetchV5

+ SessionId int32

+ ThrottleTimeMs int32

+ type FetchResponseV4 struct

+ Responses []ResponseFetchV4

+ ThrottleTimeMs int32

+ type FetchResponseV5 struct

+ Responses []ResponseFetchV5

+ ThrottleTimeMs int32

+ type FetchResponseV7 struct

+ ErrorCode int16

+ Responses []ResponseFetchV5

+ SessionId int32

+ ThrottleTimeMs int32

+ type FetchTopicV0 struct

+ Partitions []FetchPartitionV0

+ Topic string

+ type FetchTopicV5 struct

+ Partitions []FetchPartitionV5

+ Topic string

+ type FetchTopicV9 struct

+ Partitions []FetchPartitionV9

+ Topic string

+ type ForgottenTopicsDataV7 struct

+ Partitions []int32

+ Topic string

+ type GroupMessage interface

+ Group func() string

+ type KafkaPayload struct

+ Data interface{}

+ func (h KafkaPayload) MarshalJSON() ([]byte, error)

+ type KafkaPayloader interface

+ MarshalJSON func() ([]byte, error)

+ type KafkaWrapper struct

+ Details interface{}

+ Method string

+ Url string

+ type ListOffsetsRequestPartitionV0 struct

+ MaxNumOffsets int32

+ PartitionIndex int32

+ Timestamp int64

+ type ListOffsetsRequestPartitionV1 struct

+ PartitionIndex int32

+ Timestamp int64

+ type ListOffsetsRequestPartitionV4 struct

+ CurrentLeaderEpoch int32

+ PartitionIndex int32

+ Timestamp int64

+ type ListOffsetsRequestTopicV0 struct

+ Name string

+ Partitions []ListOffsetsRequestPartitionV0

+ type ListOffsetsRequestTopicV1 struct

+ Name string

+ Partitions []ListOffsetsRequestPartitionV1

+ type ListOffsetsRequestTopicV4 struct

+ Name string

+ Partitions []ListOffsetsRequestPartitionV4

+ type ListOffsetsRequestV0 struct

+ ReplicaId int32

+ Topics []ListOffsetsRequestTopicV0

+ type ListOffsetsRequestV1 struct

+ ReplicaId int32

+ Topics []ListOffsetsRequestTopicV1

+ type ListOffsetsRequestV2 struct

+ IsolationLevel int8

+ ReplicaId int32

+ Topics []ListOffsetsRequestTopicV1

+ type ListOffsetsRequestV4 struct

+ ReplicaId int32

+ Topics []ListOffsetsRequestTopicV4

+ type ListOffsetsResponsePartitionV0 struct

+ ErrorCode int16

+ OldStyleOffsets int64

+ PartitionIndex int32

+ type ListOffsetsResponsePartitionV1 struct

+ ErrorCode int16

+ Offset int64

+ PartitionIndex int32

+ Timestamp int64

+ type ListOffsetsResponsePartitionV4 struct

+ ErrorCode int16

+ LeaderEpoch int32

+ Offset int64

+ PartitionIndex int32

+ Timestamp int64

+ type ListOffsetsResponseTopicV0 struct

+ Name string

+ Partitions []ListOffsetsResponsePartitionV0

+ type ListOffsetsResponseTopicV1 struct

+ Name string

+ Partitions []ListOffsetsResponsePartitionV1

+ type ListOffsetsResponseTopicV4 struct

+ Name string

+ Partitions []ListOffsetsResponsePartitionV4

+ type ListOffsetsResponseV0 struct

+ Topics []ListOffsetsResponseTopicV0

+ type ListOffsetsResponseV1 struct

+ Topics []ListOffsetsResponseTopicV1

+ type ListOffsetsResponseV2 struct

+ ThrottleTimeMs int32

+ Topics []ListOffsetsResponseTopicV1

+ type ListOffsetsResponseV4 struct

+ Topics []ListOffsetsResponseTopicV4

+ type Merger interface

+ Merge func(messages []Message, results []interface{}) (Message, error)

+ type Message interface

+ ApiKey func() ApiKey

+ type MessageBlock struct

+ Msg *MessageV0

+ Offset int64

+ type MessageSet struct

+ Messages []*MessageBlock

+ OverflowMessage bool

+ PartialTrailingMessage bool

+ type MessageV0 struct

+ Codec int8

+ CompressionLevel int

+ Key []byte

+ LogAppendTime bool

+ Set *MessageSet

+ Timestamp time.Time

+ Value []byte

+ Version int8

+ type MetadataRequestTopicV0 struct

+ Name string

+ type MetadataRequestTopicV10 struct

+ Name string

+ UUID UUID

+ type MetadataRequestV0 struct

+ Topics []MetadataRequestTopicV0

+ type MetadataRequestV10 struct

+ AllowAutoTopicCreation bool

+ IncludeClusterAuthorizedOperations bool

+ IncludeTopicAuthorizedOperations bool

+ Topics []MetadataRequestTopicV10

+ type MetadataRequestV11 struct

+ AllowAutoTopicCreation bool

+ IncludeTopicAuthorizedOperations bool

+ Topics []MetadataRequestTopicV10

+ type MetadataRequestV4 struct

+ AllowAutoTopicCreation bool

+ Topics []MetadataRequestTopicV0

+ type MetadataRequestV8 struct

+ AllowAutoTopicCreation bool

+ IncludeClusterAuthorizedOperations bool

+ IncludeTopicAuthorizedOperations bool

+ Topics []MetadataRequestTopicV0

+ type MetadataResponseV0 struct

+ Brokers []BrokerV0

+ Topics []TopicV0

+ type MetadataResponseV1 struct

+ Brokers []BrokerV1

+ ControllerID int32

+ Topics []TopicV1

+ type MetadataResponseV10 struct

+ Brokers []BrokerV1

+ ClusterAuthorizedOperations int32

+ ClusterID string

+ ControllerID int32

+ ThrottleTimeMs int32

+ Topics []TopicV10

+ type MetadataResponseV11 struct

+ Brokers []BrokerV1

+ ClusterID string

+ ControllerID int32

+ ThrottleTimeMs int32

+ Topics []TopicV10

+ type MetadataResponseV2 struct

+ Brokers []BrokerV1

+ ClusterID string

+ ControllerID int32

+ Topics []TopicV1

+ type MetadataResponseV3 struct

+ Brokers []BrokerV1

+ ClusterID string

+ ControllerID int32

+ ThrottleTimeMs int32

+ Topics []TopicV1

+ type MetadataResponseV5 struct

+ Brokers []BrokerV1

+ ClusterID string

+ ControllerID int32

+ ThrottleTimeMs int32

+ Topics []TopicV5

+ type MetadataResponseV7 struct

+ Brokers []BrokerV1

+ ClusterID string

+ ControllerID int32

+ ThrottleTimeMs int32

+ Topics []TopicV7

+ type MetadataResponseV8 struct

+ Brokers []BrokerV1

+ ClusterAuthorizedOperations int32

+ ClusterID string

+ ControllerID int32

+ ThrottleTimeMs int32

+ Topics []TopicV8

+ type Partition struct

+ Error int16

+ ID int32

+ ISR []int32

+ Leader int32

+ Offline []int32

+ Replicas []int32

+ type PartitionData struct

+ Index int32

+ Records Records

+ Unknown int32

+ type PartitionResponseFetchV0 struct

+ ErrorCode int16

+ HighWatermark int64

+ Partition int32

+ RecordSet Records

+ type PartitionResponseFetchV11 struct

+ AbortedTransactions AbortedTransactionsV4

+ ErrorCode int16

+ HighWatermark int64

+ LastStableOffset int64

+ LogStartOffset int64

+ Partition int32

+ PreferredReadReplica int32

+ RecordSet Records

+ type PartitionResponseFetchV4 struct

+ AbortedTransactions AbortedTransactionsV4

+ ErrorCode int16

+ HighWatermark int64

+ LastStableOffset int64

+ Partition int32

+ RecordSet Records

+ type PartitionResponseFetchV5 struct

+ AbortedTransactions AbortedTransactionsV4

+ ErrorCode int16

+ HighWatermark int64

+ LastStableOffset int64

+ LogStartOffset int64

+ Partition int32

+ RecordSet Records

+ type PartitionResponseV0 struct

+ BaseOffset int64

+ ErrorCode int16

+ Index int32

+ type PartitionResponseV2 struct

+ BaseOffset int64

+ ErrorCode int16

+ Index int32

+ LogAppendTimeMs int64

+ type PartitionResponseV5 struct

+ BaseOffset int64

+ ErrorCode int16

+ Index int32

+ LogAppendTimeMs int64

+ LogStartOffset int64

+ type PartitionResponseV8 struct

+ BaseOffset int64

+ ErrorCode int16

+ ErrorMessage string

+ Index int32

+ LogAppendTimeMs int64

+ LogStartOffset int64

+ RecordErrors RecordErrors

+ type Partitions struct

+ Length int32

+ PartitionData PartitionData

+ type PartitionsV0 struct

+ ErrorCode int16

+ IsrNodes int32

+ LeaderId int32

+ PartitionIndex int32

+ ReplicaNodes int32

+ type PartitionsV5 struct

+ ErrorCode int16

+ IsrNodes int32

+ LeaderId int32

+ OfflineReplicas int32

+ PartitionIndex int32

+ ReplicaNodes int32

+ type PartitionsV7 struct

+ ErrorCode int16

+ IsrNodes int32

+ LeaderEpoch int32

+ LeaderId int32

+ OfflineReplicas int32

+ PartitionIndex int32

+ ReplicaNodes int32

+ type PreparedMessage interface

+ Prepare func(apiVersion int16)

+ type ProduceRequestV0 struct

+ RequiredAcks RequiredAcks

+ Timeout int32

+ TopicData []TopicData

+ type ProduceRequestV3 struct

+ RequiredAcks RequiredAcks

+ Timeout int32

+ TopicData []TopicData

+ TransactionalID string

+ type ProduceResponseV0 struct

+ Responses []ResponseV0

+ type ProduceResponseV1 struct

+ Responses []ResponseV0

+ ThrottleTimeMs int32

+ type ProduceResponseV2 struct

+ Responses []ResponseV2

+ ThrottleTimeMs int32

+ type ProduceResponseV5 struct

+ Responses []ResponseV5

+ ThrottleTimeMs int32

+ type ProduceResponseV8 struct

+ Responses []ResponseV8

+ ThrottleTimeMs int32

+ type RecordBatch struct

+ Attributes int16

+ BaseOffset int64

+ BaseSequence int32

+ BatchLength int32

+ Crc int32

+ FirstTimestamp int64

+ LastOffsetDelta int32

+ Magic int8

+ MaxTimestamp int64

+ PartitionLeaderEpoch int32

+ ProducerEpoch int16

+ ProducerId int64

+ Record []RecordV0

+ type RecordErrors struct

+ BatchIndex int32

+ BatchIndexErrorMessage string

+ type RecordHeader struct

+ HeaderKey string

+ HeaderKeyLength int8

+ HeaderValueLength int8

+ Value string

+ type RecordV0 struct

+ Attributes int8

+ Headers []RecordHeader

+ Key string

+ KeyLength int8

+ OffsetDelta int8

+ TimestampDelta int8

+ Unknown int8

+ Value string

+ ValueLen int8

+ type Records struct

+ RecordBatch RecordBatch

+ type Request struct

+ ApiKey ApiKey

+ ApiKeyName string

+ ApiVersion int16

+ CaptureTime time.Time

+ ClientID string

+ CorrelationID int32

+ Payload interface{}

+ Size int32

+ type RequestResponsePair struct

+ Request Request

+ Response Response

+ type RequiredAcks int16

+ const RequireAll

+ const RequireNone

+ const RequireOne

+ type Response struct

+ CaptureTime time.Time

+ CorrelationID int32

+ Payload interface{}

+ Size int32

+ type ResponseFetchV0 struct

+ PartitionResponses []PartitionResponseFetchV0

+ Topic string

+ type ResponseFetchV11 struct

+ PartitionResponses []PartitionResponseFetchV11

+ Topic string

+ type ResponseFetchV4 struct

+ PartitionResponses []PartitionResponseFetchV4

+ Topic string

+ type ResponseFetchV5 struct

+ PartitionResponses []PartitionResponseFetchV5

+ Topic string

+ type ResponseV0 struct

+ Name string

+ PartitionResponses []PartitionResponseV0

+ type ResponseV2 struct

+ Name string

+ PartitionResponses []PartitionResponseV2

+ type ResponseV5 struct

+ Name string

+ PartitionResponses []PartitionResponseV5

+ type ResponseV8 struct

+ Name string

+ PartitionResponses []PartitionResponseV8

+ type Topic struct

+ Error int16

+ Name string

+ Partitions map[int32]Partition

+ type TopicData struct

+ Partitions Partitions

+ Topic string

+ type TopicV0 struct

+ ErrorCode int16

+ Name string

+ Partitions []PartitionsV0

+ type TopicV1 struct

+ ErrorCode int16

+ IsInternal bool

+ Name string

+ Partitions []PartitionsV0

+ type TopicV10 struct

+ ErrorCode int16

+ IsInternal bool

+ Name string

+ Partitions []PartitionsV7

+ TopicAuthorizedOperations int32

+ TopicID UUID

+ type TopicV5 struct

+ ErrorCode int16

+ IsInternal bool

+ Name string

+ Partitions []PartitionsV5

+ type TopicV7 struct

+ ErrorCode int16

+ IsInternal bool

+ Name string

+ Partitions []PartitionsV7

+ type TopicV8 struct

+ ErrorCode int16

+ IsInternal bool

+ Name string

+ Partitions []PartitionsV7

+ TopicAuthorizedOperations int32

+ type UUID struct

+ ClockSeq int16

+ NodePart1 int32

+ NodePart22 int16

+ TimeHiAndVersion int16

+ TimeLow int32

+ TimeMid int16

v0.1.1

Nov 30, 2022

v0.1.0

Nov 30, 2022