Categorygithub.com/JECSand/identity-servicepkgkafka
package
0.0.0-20230710010217-e5a474cc7f5d
Repository: https://github.com/jecsand/identity-service.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
6
Dependents
10
Files
166 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.