package
0.2.2
Repository: https://github.com/gig/kafka-client.git
Documentation: pkg.go.dev

# Functions

NewConsumerConfig returns ConsumerConfig with sane defaults.
NewOffsetRange returns a new OffsetRange with the LowOffset of the range as specified.
NewStaticNameResolver returns a instance of NameResolver that relies on a static map of topic to list of brokers and map of topics to cluster.

# Constants

OffsetNewest option uses sequence number of newest message as the current offset.
OffsetOldest uses sequence number of oldest known message as the current offset.

# Structs

No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author

# Interfaces

No description provided by the author
No description provided by the author
No description provided by the author

# Type aliases

No description provided by the author