Buffer option for adjusting the incoming messages buffer.

New constructor.

Start option for adjusting the start point in the topic.

Timeout option for adjusting the timeout of the connection.

Version option for setting the Kafka version.

OffsetNewest starts consuming from the newest available message in the topic.

OffsetOldest starts consuming from the oldest available message in the topic.

Factory definition of a consumer factory.

Offset defines the offset of messages inside a topic.

OptionFunc definition for configuring the consumer in a functional way.