Go to main page
Imports
- github.com/segmentio/kafka-go/compress
- github.com/segmentio/kafka-go/protocol
- github.com/segmentio/kafka-go/protocol/addoffsetstotxn
- github.com/segmentio/kafka-go/protocol/addpartitionstotxn
- github.com/segmentio/kafka-go/protocol/alterclientquotas
- github.com/segmentio/kafka-go/protocol/alterconfigs
- github.com/segmentio/kafka-go/protocol/alterpartitionreassignments
- github.com/segmentio/kafka-go/protocol/alteruserscramcredentials
- github.com/segmentio/kafka-go/protocol/apiversions
- github.com/segmentio/kafka-go/protocol/consumer
- github.com/segmentio/kafka-go/protocol/createacls
- github.com/segmentio/kafka-go/protocol/createpartitions
- github.com/segmentio/kafka-go/protocol/createtopics
- github.com/segmentio/kafka-go/protocol/deleteacls
- github.com/segmentio/kafka-go/protocol/deletegroups
- github.com/segmentio/kafka-go/protocol/deletetopics
- github.com/segmentio/kafka-go/protocol/describeacls
- github.com/segmentio/kafka-go/protocol/describeclientquotas
- github.com/segmentio/kafka-go/protocol/describeconfigs
- github.com/segmentio/kafka-go/protocol/describegroups
- github.com/segmentio/kafka-go/protocol/describeuserscramcredentials
- github.com/segmentio/kafka-go/protocol/electleaders
- github.com/segmentio/kafka-go/protocol/endtxn
- github.com/segmentio/kafka-go/protocol/fetch
- github.com/segmentio/kafka-go/protocol/findcoordinator
- github.com/segmentio/kafka-go/protocol/heartbeat
- github.com/segmentio/kafka-go/protocol/incrementalalterconfigs
- github.com/segmentio/kafka-go/protocol/initproducerid
- github.com/segmentio/kafka-go/protocol/joingroup
- github.com/segmentio/kafka-go/protocol/leavegroup
- github.com/segmentio/kafka-go/protocol/listgroups
- github.com/segmentio/kafka-go/protocol/listoffsets
- github.com/segmentio/kafka-go/protocol/listpartitionreassignments
- github.com/segmentio/kafka-go/protocol/metadata
- github.com/segmentio/kafka-go/protocol/offsetcommit
- github.com/segmentio/kafka-go/protocol/offsetdelete
- github.com/segmentio/kafka-go/protocol/offsetfetch
- github.com/segmentio/kafka-go/protocol/produce
- github.com/segmentio/kafka-go/protocol/rawproduce
- github.com/segmentio/kafka-go/protocol/saslauthenticate
- github.com/segmentio/kafka-go/protocol/saslhandshake
- github.com/segmentio/kafka-go/protocol/syncgroup
- github.com/segmentio/kafka-go/protocol/txnoffsetcommit
- github.com/segmentio/kafka-go/sasl