kafka

type CommonKafka interface {
	GetKafkaWriter() Writer
	Close()
	SetLog(log.Logger)
}

type ConfigDI interface {
	NewKafkaWriter(ctx context.Context, topic string) Writer
	NewKafkaReader(ctx context.Context, groupID, topic string, l log.Logger) Reader
}

type KafkaConfig struct {
	Brokers []string
}

type Reader interface {
	Read() (map[string]string, []byte, error)
	ReadHandler(handler ReaderHandler) error
	Close() error
}

type ReaderHandler func(headers map[string]string, data []byte) error

type Writer interface {
	SetLog(log.Logger)
	Message(headers map[string][]byte, msg []byte) error
	Close() error
}