AvroFormat set Format to Avro.

BinaryFormat set Format to Binary.

EarliestOffset set Offset to Earliest.

JSONFormat set Format to JSON.

LargestOffset set Offset to Latest.

LatestOffset set Offset to Latest.

New returns a Kafka instance with default setting.

SetAccept applies Accept to Kafka.

SetContentType applies ContentType to Kafka.

SetTimeout applies Timeout to Kafka.

SetURL applies URL to Kafka.

SmallestOffset set Offset to Earliest.

Stringer returns formated string.

URLJoin joins url with path and return the whole url string.

V1Version set Version to V1.

V2Version set Version to V2.

Avro formated consumer.

Binary formated consumer.

Earliest is the oldest offset for API v2.

JSON formated consumer.

Largest is the newest offset for API v1.

Latest is the newest offset for API v2.

Smallest is the oldest offset for API v1.

V1 is API v1.

V2 is API v2.

Defaults for Kafka.