NewKafkaProducer constructs a new Producer that will produce into the given Kafka broker.

ConcurrentRouter is a wrapper around a generic Router which controls concurrent access.

Producer is a wrapper for kafka.Producer which handles delivery failure in a canonical way.

TopicRouter is a Router that routes based on the Kafka topic of consumed messages.

Consumer is the generic interface for all consumers.

KeyRouter is a generic router for Kafka which routes consumed messages to a set of configured handlers based on a key.

LowLevelProducer provides access to synchronous sending routines.

Handler is a function used in a KeyRouter which handles a single kind of message.