package
1.8.1
Repository: https://github.com/cswank/kcli.git
Documentation: pkg.go.dev

# Functions

Concurrency is used to set the size of the search worker pool.
New returns a kafka Client.
WithDecoder is used to insert a Decoder plugin.

# Structs

Client fetches from kafka.
Message holds information about a single kafka message.
Partition holds information about a kafka partition.

# Interfaces

Decoder is the interface that is required of plugins.

# Type aliases

Opt is a func that sets an attribute on Client.