APM Queue

Package kafka abstracts the production and consumption of records to and from Kafka.

Package metrictest provides helpers for metric testing.

Package queuecontext provides convenient wrappers for storing and accessing a stored metadata.

Package systemtest holds system/integration tests that test the apm-queue/kafka and apm-queue/pubsublite producer and consumer behaviour against real brokers/clusters.

AtLeastOnceDeliveryType acknowledges the message after it has been processed.

AtMostOnceDeliveryType acknowledges the message as soon as it's received and decoded, without waiting for the message to be processed.

ErrConsumerAlreadyRunning is returned by consumer.Run if it has already been called.

Record wraps a record's value with the topic where it's produced / consumed.

TopicConsumer is used to monitor a set of consumer topics.

Consumer wraps the implementation details of the consumer implementation.

Processor defines record processing signature.

Producer wraps the producer implementation details.

DeliveryType for the consumer.

ProcessorFunc is a function type that implements the Processor interface.

Topic represents a destination topic where to produce a message/record.