Versions in this module Expand all Collapse all v0 v0.1.0 Mar 27, 2023 Changes in this version + func NewConsumerHandler(cf *config.Configuration, db *database.DB) (iface.ConsumerHandler, error) + func NewKafkaProducer(cf *config.Configuration) (iface.KafkaProducer, error)
Go to main page