kafka

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

type KafkaReaderConfig struct {
	Brokers       []string
	GroupId       string
	Topic         string
	QueueCapacity int
	MinBytes      int
	MaxBytes      int
}

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

type KafkaWritterConfig struct {
	Brokers      []string
	Topic        string
	MaxAttempts  int
	BatchSize    int
	BatchTimeout time.Duration
	WriteTimeout time.Duration
	LogFileName  string
}

type Message []byte