Directories
¶
| Path | Synopsis |
|---|---|
|
kadm
module
|
|
|
Package kbin contains Kafka primitive reading and writing functions.
|
Package kbin contains Kafka primitive reading and writing functions. |
|
Package kerr contains Kafka errors.
|
Package kerr contains Kafka errors. |
|
kfake
module
|
|
|
Package kgo provides a pure Go efficient Kafka client for Kafka 0.8+ with support for transactions, regex topic consuming, the latest partition strategies, and more.
|
Package kgo provides a pure Go efficient Kafka client for Kafka 0.8+ with support for transactions, regex topic consuming, the latest partition strategies, and more. |
|
internal/sticky
Package sticky provides sticky partitioning strategy for Kafka, with a complete overhaul to be faster, more understandable, and optimal.
|
Package sticky provides sticky partitioning strategy for Kafka, with a complete overhaul to be faster, more understandable, and optimal. |
|
internal/xsync
Package xsync provides Mutex and RWMutex types that are aliases for sync.Mutex / sync.RWMutex in normal builds and channel-backed reimplementations under the "synctests" build tag.
|
Package xsync provides Mutex and RWMutex types that are aliases for sync.Mutex / sync.RWMutex in normal builds and channel-backed reimplementations under the "synctests" build tag. |
|
kmsg
module
|
|
|
Package kversion specifies versions for Kafka request keys.
|
Package kversion specifies versions for Kafka request keys. |
|
Package sasl specifies interfaces that any SASL authentication must provide to interop with Kafka SASL.
|
Package sasl specifies interfaces that any SASL authentication must provide to interop with Kafka SASL. |
|
aws
Package aws provides AWS_MSK_IAM sasl authentication as specified in the Java source.
|
Package aws provides AWS_MSK_IAM sasl authentication as specified in the Java source. |
|
oauth
Package oauth provides OAUTHBEARER sasl authentication as specified in RFC7628.
|
Package oauth provides OAUTHBEARER sasl authentication as specified in RFC7628. |
|
plain
Package plain provides PLAIN sasl authentication as specified in RFC4616.
|
Package plain provides PLAIN sasl authentication as specified in RFC4616. |
|
scram
Package scram provides SCRAM-SHA-256 and SCRAM-SHA-512 sasl authentication as specified in RFC5802.
|
Package scram provides SCRAM-SHA-256 and SCRAM-SHA-512 sasl authentication as specified in RFC5802. |
|
kerberos
module
|
|
|
sr
module
|
Click to show internal directories.
Click to hide internal directories.