Versions in this module Expand all Collapse all v2 v2.1.0 Mar 25, 2022 Changes in this version + type Cfg struct + End int64 + KeyGrep string + Start int64 + Topic string + URL string + Verbose bool + type Kafka struct + func NewKafka(ctx context.Context, cfg Cfg, decoder protoparser.Decoder, ...) (*Kafka, error) + func (k *Kafka) Run() <-chan error
Go to main page