Categorygithub.com/dragonator/notification-servicepkgkafka
package
0.0.0-20230724103943-0f1d0c96f81e
Repository: https://github.com/dragonator/notification-service.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
4
Dependents
1
Files
103 SLOC

# Functions

NewConsumer is a constructor function for Consumer.
NewProducer is a constructor function for Producer.

# Structs

Consumer implements functionality to consume kafka messages.
Producer implements functionality to produce kafka messages.

# Interfaces

Processor is a contract to a kafka message processor.
Reader is a contract to a kafka writer.
Writer is a contract to a kafka writer.