kafka

type ErrorLogger struct {
}

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

type Logger struct {
}

type Options struct {
	Brokers          []string
	Subjects         []string
	GroupId          string
	Concurrency      int
	QueueCapacity    int
	MinBytes         int
	MaxBytes         int
	StartOffset      int64
	ReadBatchTimeout time.Duration
	MaxWait          time.Duration
}