DefaultOptions returns the default options.

NewBufferedDLQ returns a DLQ that is backed by a buffered async sarama producer.

NewClusterConsumer returns a new single cluster consumer.

NewMultiClusterConsumer returns a new consumer that consumes messages from multiple Kafka clusters.

NewNoopDLQ returns returns a noop DLQ.

NewPartitionConsumer returns a kafka consumer that can read messages from a given [ topic, partition ] tuple.

NewPartitionConsumerWithoutCommit returns a kafka consumer that can read messages from a given [ topic, partition ] tuple where commits are disabled.

NewRangePartitionConsumer returns a kafka consumer that can read messages from a given [ topic, partition ] tuple.

NewRetryDLQMultiplexer returns a DLQ that will produce messages to retryTopic or dlqTopic depending on the threshold.

NewSaramaClient returns an internal sarama Client, which can be safely closed multiple times.

NewSaramaConsumer returns a new SaramaConsumer that has a Close method that can be called multiple times.

NewSaramaProducer returns a new AsyncProducer that has Close method that can be called multiple times.

NewTopicConsumer returns a new TopicConsumer for consuming from a single topic.

NoopDLQMetadataDecoder does no decoding and returns a default DLQMetadata object.

ProtobufDLQMetadataDecoder uses proto.Unmarshal to decode protobuf encoded binary into the DLQMetadata object.

DLQConsumerGroupNameSuffix is the consumer group name used by the DLQ merge process.

DLQErrorQType is the error queue for DLQ.

RetryQErrorQType is the error queue for the retryQ.

DLQMetadata contains metadata from the original kafka message.