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. |
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.