Package client implements the synchronous and asynchronous kafka Producers and the kafka Consumer.

Package mux implements the session multiplexer that allows multiple plugins to share a single connection to a Kafka broker.

FromExistingMux is used mainly for testing purposes.

NewPlugin creates a new Plugin with the provided Options.

UseDeps returns Option that can inject custom dependencies.

DefaultPlugin is a default instance of Plugin.

Deps groups dependencies injected into the plugin so that they are logically separated from other plugin fields.

Plugin provides API for interaction with kafka brokers.

Option is a function that can be used in NewPlugin to customize Plugin.