pkg.gl

Categorygithub.com/Goboolean/commonpkgkafka

package

0.0.0-20231130153141-cb54596b217d

Repository: https://github.com/goboolean/common.git

Documentation: pkg.go.dev

# Functions

NewConsumer

example: p, err := NewConsumer[*model.Event](&resolver.ConfigMap{ "BOOTSTRAP_HOST": os.Getenv("KAFKA_BOOTSTRAP_HOST"), "REGISTRY_HOST": os.Getenv("KAFKA_REGISTRY_HOST"), // optional "GROUP_ID": "GROUP_ID", "PROCESSOR_COUNT": os.Getenv("KAFKA_PROCESSOR_COUNT"), "TOPIC": "TOPIC", }, subscribeListenerImpl).

NewProducer

example: p, err := NewProducer(&resolver.ConfigMap{ "BOOTSTRAP_HOST": os.Getenv("KAFKA_BOOTSTRAP_HOST"), "REGISTRY_HOST": os.Getenv("KAFKA_REGISTRY_HOST"), // optional }).