sarama

Documentation

Index

• func NewConsumerHandler(cf *config.Configuration, db *database.DB) (iface.ConsumerHandler, error)
• func NewKafkaProducer(cf *config.Configuration) (iface.KafkaProducer, error)
• type EventHandler

Functions

func NewConsumerHandler

func NewConsumerHandler(cf *config.Configuration, db *database.DB) (iface.ConsumerHandler, error)

func NewKafkaProducer

func NewKafkaProducer(cf *config.Configuration) (iface.KafkaProducer, error)

Types

type EventHandler

type EventHandler interface {
	Handle(topic string, eventBytes []byte)
}