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.

WithFirstOffset tells Kafka consumer to read from the beginning of uncommitted offset.

WithMessageDecodeFunc allow to replace DefaultMessageDecodeFunc().

WithMessageEncodeFunc allow to replace DefaultMessageEncodeFunc.

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

Consumer represents a wrapper around kafka.Consumer.

Producer represents a wrapper around kafka.Producer.

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().