Versions in this module Expand all Collapse all v0 v0.1.0 Oct 18, 2022 Changes in this version + func GetHeader(headers []kafka.Header, key string) (*kafka.Header, error) + func NewConsumer(opts *config.Options) (*kafka.Consumer, error)
Go to main page