Addresses set the host addresses to be used by the mq.

Codec sets the codec used for encoding/decoding used where.

DisableAutoAck will disable auto acking of messages after they have been handled.

ErrorHandler set the error handler.

PublishContext set context.

Queue sets the name of the queue to share messages on.

user/password/algorithm are needed by SASL auth.

Secure communication with the mq.

SetTLSConfig Specify TLS Config.

SubscribeContext set context.

SubscribeRetryNum sets RetryNum.

SubscribeStrategy sets Strategy.

Version set the kafka version for sarama.

Message is the message entity.

Codec is a simple encoding interface used for the mq/transport.

Event is given to a subscription handler for processing.

Subscriber is a convenience return type for the Subscribe method.

Handler is used to process messages via a subscription of a topic.