Categorygithub.com/novabankapp/golang.common.infrastructurekafka
package
1.6.0
Repository: https://github.com/novabankapp/golang.common.infrastructure.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
6
Dependents
0
Files
172 SLOC

# Functions

NewConsumerGroup kafka consumer group constructor.
No description provided by the author
NewKafkaReader create new configured kafka reader.
NewProducer create new kafka producer.
NewWriter create new configured kafka writer.

# Structs

No description provided by the author
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.