package service import ( "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) type ConsumerHandler func(*kafka.Message) error type Consumer interface { Service Subscribe([]string, chan uint32) (chan *kafka.Message, error) RegisterHandlers(...ConsumerHandler) } type Producer interface { Service Produce(*kafka.Message) error }