kafka

type Config struct {
	ZookeeperConnectionString string
	ConsumerGroup             string
	Topics                    []string
	ConsumerGroupConfig       *consumergroup.Config
	Err                       chan error
	Logger                    *logger.UPPLogger
}

type Consumer interface {
	StartListening(messageHandler func(message FTMessage) error)
	Shutdown()
	ConnectivityCheck() error
}

type ConsumerGrouper interface {
	Errors() <-chan error
	Messages() <-chan *sarama.ConsumerMessage
	CommitUpto(message *sarama.ConsumerMessage) error
	Close() error
	Closed() bool
}

type FTMessage struct {
	Headers map[string]string
	Body    string
}

type MessageConsumer struct {
	// contains filtered or unexported fields
}

type MessageProducer struct {
	// contains filtered or unexported fields
}

type Producer interface {
	SendMessage(message FTMessage) error
	ConnectivityCheck() error
	Shutdown()
}