Buffer option for adjusting the incoming messages buffer.

New constructor.

Timeout option for adjusting the timeout of the connection.

Version option for setting the Kafka version.

Factory definition of a consumer factory.

OptionFunc definition for configuring the consumer in a functional way.