# Functions
GzipCompression enables gzip compression with the default compression level.
Lz4Compression enables lz4 compression with the fastest compression level.
NewConsumer creates a new instance of a Consumer.
NewManager returns a new Manager with the given config.
NewProducer returns a new Producer with the given config.
NoCompression is a compression option that avoids compression.
SnappyCompression enables snappy compression.
ZstdCompression enables zstd compression with the default compression level.
# Variables
ErrCommitFailed may be returned by `consumer.Run` when DeliveryType is apmqueue.AtMostOnceDelivery.
# Structs
CommonConfig defines common configuration for Kafka consumers, producers, and managers.
Consumer wraps a Kafka consumer and the consumption implementation details.
ConsumerConfig defines the configuration for the Kafka consumer.
Manager manages Kafka topics.
ManagerConfig holds configuration for managing Kafka topics.
Producer publishes events to Kafka.
ProducerConfig holds configuration for publishing events to Kafka.
TopicCreator creates Kafka topics.
TopicCreatorConfig holds configuration for creating Kafka topics.
# Type aliases
BatchWriteListener specifies a callback function that is invoked after a batch is successfully produced to a Kafka broker.
CompressionCodec configures how records are compressed before being sent.
SASLMechanism type alias to sasl.Mechanism.
TopicAttributeFunc run on `kgo.HookProduceBatchWritten` and `kgo.HookFetchBatchRead` for each topic/partition.
TopicLogFieldFunc is a function that returns a zap.Field for a given topic.