// GetNewKafkaReader create new kafka reader
GetNewKafkaReader create new kafka reader
// GetNewKafkaReader create new kafka reader
func (c *consumerGroup) GetNewKafkaReader(kafkaURL []string, groupTopics []string, groupID string) *kafka.Reader {
	return kafka.NewReader(kafka.ReaderConfig{
		Brokers:                kafkaURL,
		GroupID:                groupID,
		GroupTopics:            groupTopics,
		MinBytes:               minBytes,
		MaxBytes:               maxBytes,
		QueueCapacity:          queueCapacity,
		HeartbeatInterval:      heartbeatInterval,
		CommitInterval:         commitInterval,
		PartitionWatchInterval: partitionWatchInterval,
		MaxAttempts:            maxAttempts,
		MaxWait:                maxWait,
		Dialer: &kafka.Dialer{
			Timeout: dialTimeout,
		},
	})
}
func ( c * consumerGroup ) GetNewKafkaReader ( kafkaURL [ ] string , groupTopics [ ] string , groupID string ) * kafka . Reader { return kafka . NewReader ( kafka . ReaderConfig { Brokers : kafkaURL , GroupID : groupID , GroupTopics : groupTopics , MinBytes : minBytes , MaxBytes : maxBytes , QueueCapacity : queueCapacity , HeartbeatInterval : heartbeatInterval , CommitInterval : commitInterval , PartitionWatchInterval : partitionWatchInterval , MaxAttempts : maxAttempts , MaxWait : maxWait , Dialer : & kafka . Dialer { Timeout : dialTimeout , } , } ) }
GetNewKafkaReader create new kafka reader
GetNewKafkaReader create new kafka reader