Categorygithub.com/beatlabs/proton/v2internalconsumer
package
2.1.0
Repository: https://github.com/beatlabs/proton.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
8
Dependents
1
Files
198 SLOC

# Functions

NewKafka returns a new instance of this consumer or an error if something isn't right.

# Structs

Cfg is the configuration of this consumer.
Kafka is the consumer itself.