consumer

type Consumer interface {
	ConsumeMessages() error
}

type ElasticSearchTarget struct {
	Server string
}

type KafkaSource struct {
	Brokers []string
	Topic   string
	Offset  int64
	GroupId string

	Reader *kafka.Reader
}

type PrinterConsumer struct {
	Source       KafkaSource
	WorkerCount  int
	ConsumerName string
	Debug        bool
}

type ProductionConsumer struct {
	Source      KafkaSource
	Target      ElasticSearchTarget
	WorkerCount int
	BulkSize    int
	Debug       bool
}