// NewKafkaReader create new configured kafka reader
NewKafkaReader create new configured kafka reader
// NewKafkaReader create new configured kafka reader
func NewKafkaReader(kafkaURL []string, topic, groupID string, errLogger kafka.Logger) *kafka.Reader {
	return kafka.NewReader(kafka.ReaderConfig{
		Brokers:                kafkaURL,
		GroupID:                groupID,
		Topic:                  topic,
		MinBytes:               minBytes,
		MaxBytes:               maxBytes,
		QueueCapacity:          queueCapacity,
		HeartbeatInterval:      heartbeatInterval,
		CommitInterval:         commitInterval,
		PartitionWatchInterval: partitionWatchInterval,
		ErrorLogger:            errLogger,
		MaxAttempts:            maxAttempts,
		MaxWait:                time.Second,
		Dialer: &kafka.Dialer{
			Timeout: dialTimeout,
		},
	})
}
func NewKafkaReader ( kafkaURL [ ] string , topic , groupID string , errLogger kafka . Logger ) * kafka . Reader { return kafka . NewReader ( kafka . ReaderConfig { Brokers : kafkaURL , GroupID : groupID , Topic : topic , MinBytes : minBytes , MaxBytes : maxBytes , QueueCapacity : queueCapacity , HeartbeatInterval : heartbeatInterval , CommitInterval : commitInterval , PartitionWatchInterval : partitionWatchInterval , ErrorLogger : errLogger , MaxAttempts : maxAttempts , MaxWait : time . Second , Dialer : & kafka . Dialer { Timeout : dialTimeout , } , } ) }
NewKafkaReader create new configured kafka reader
NewKafkaReader create new configured kafka reader