kafka

type Kafka struct {
	Topic            string   `config:"topic"`
	BatchSize        int      `config:"batch_size"`
	BatchTimeoutInMs int      `config:"batch_timeout_in_ms"`
	RequiredAcks     int      `config:"required_acks"`
	Brokers          []string `config:"brokers"`
	// contains filtered or unexported fields
}