Client that binds to kafka broker.
Logger trait allowing to attach any Logging framework required.
Message read from the topic.
Offset of the message
Key of the message
Offset of last message in the topic
Starting from this offset will assure that we will read always from very oldest message (head) kept in topic *
Starting from this offset will assure we starting with most recent messages written to topic (tail) *
syntax helper to construct broker address *
Build a stream, that when run will produce single kafka client.
Ensemble to connect to. Must not be empty.
Protocol that will be used for requests. This shall be lowest common protocol supported by all brokers.
Name of the client. Name is suffixed for different type of connections to broker:
types the offset in the topic*
types correctly id of the partition*
types correctly name of the topic *