Documentation
¶
Index ¶
- func AddService(config service.Config)
- func BatchMessages(values <-chan kafka.Message, maxItems int, maxTimeout time.Duration) chan []kafka.Message
- func Handle(messages <-chan kafka.Message) <-chan kafka.Message
- func NewConsumer(kafkaURL, topic, groupID string, done context.Context) <-chan kafka.Message
- func NewProducer(kafkaURL, topic string, in <-chan kafka.Message)
- func Start(done context.Context)
- func Writer(kafkaURL, topic string) *kafka.Writer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddService ¶
func BatchMessages ¶ added in v0.3.5
func NewConsumer ¶
func NewProducer ¶
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.