DefaultMessageDecodeFunc is the default function to decode a message for ReceiveData().

DefaultMessageEncodeFunc is the default function to encode the input data for SendData().

NewConsumer creates a new instance of Consumer.

NewProducer creates a new instance of Producer.

WithAutoOffsetResetPolicy sets what to do when there is no initial offset in Kafka or if the current offset does not exist any more on the server (e.g.

WithConfigParameter extends kafka.ConfigMap with additional parameters.

WithMessageDecodeFunc allow to replace DefaultMessageDecodeFunc().

WithMessageEncodeFunc allow to replace DefaultMessageEncodeFunc.

WithProduceChannelSize sets the buffer size (in number of messages).

WithSessionTimeout sets the timeout used to detect client failures when using Kafka's group management facility.

OffsetEarliest automatically reset the offset to the earliest offset.

OffsetLatest automatically reset the offset to the latest offset.

OffsetNone throw an error to the consumerClient if no previous offset is found for the consumerClient's group.

Consumer represents a wrapper around kafka.Consumer.

Producer represents a wrapper around kafka.Producer.

Offset points to where Kafka should start to read messages from.

Option is a type alias for a function that configures Kafka client.

TDecodeFunc is the type of function used to replace the default message decoding function used by ReceiveData().

TEncodeFunc is the type of function used to replace the default message encoding function used by SendData().