Package kafka implements a client for the Kafka broker.

ParseOpts returns timeout and logger to be used based on the given options.

ToProtoMsgChan allows to receive messages through channel instead of callback.

ToProtoMsgErrChan allows to receive error messages through channel instead of callback.

WithLogger creates an option for ToChan function that specifies a logger to be used.

WithTimeout creates an option for ToChan function that defines a timeout for notification delivery.

DefaultMsgTimeout for delivery of notification.

WithLoggerOpt defines a logger that logs if delivery of notification is unsuccessful.

WithTimeoutOpt defines the maximum time allocated to deliver a notification.

Mux defines API for the plugins that use access to kafka brokers.

OffsetHandler allows to mark offset or commit.

ProtoMessage exposes parameters of a single message received from messaging system.

ProtoMessageErr represents a message that was not published successfully to a messaging system.

ProtoPartitionWatcher allows to subscribe for receiving of messages published to selected topics, partitions and offsets.

ProtoPublisher allows to publish a message of type proto.Message into messaging system.

ProtoWatcher allows to subscribe for receiving of messages published to selected topics.