Categorygithub.com/arhamj/go-commonspkgkafka
package
0.0.4
Repository: https://github.com/arhamj/go-commons.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
6
Dependents
0
Files
172 SLOC

# Functions

NewConsumerGroup kafka consumer group constructor.
NewKafkaConn create new kafka connection.
NewKafkaReader create new configured kafka reader.
NewProducer create new kafka producer.
NewWriter create new configured kafka writer.

# Structs

Config kafka config.
TopicConfig kafka topic config.

# Interfaces

No description provided by the author
MessageProcessor processor methods must implement kafka.Worker func method interface.
No description provided by the author

# Type aliases

Worker kafka consumer worker fetch and process messages from reader.