func NewSegmentioConsumer(kafkaURLs []string, topic, groupID string) (*SegmentioConsumer, error) {
	reader := kafka.NewReader(kafka.ReaderConfig{
		Brokers:                kafkaURLs,
		GroupID:                groupID,
		Topic:                  topic,
		Partition:              0,
		Dialer:                 nil,
		QueueCapacity:          0,
		MinBytes:               0,
		MaxBytes:               0,
		MaxWait:                0,
		ReadLagInterval:        0,
		GroupBalancers:         nil,
		HeartbeatInterval:      0,
		CommitInterval:         0,
		PartitionWatchInterval: 0,
		WatchPartitionChanges:  false,
		SessionTimeout:         0,
		RebalanceTimeout:       0,
		JoinGroupBackoff:       0,
		RetentionTime:          0,
		StartOffset:            0,
		ReadBackoffMin:         0,
		ReadBackoffMax:         0,
		Logger:                 nil,
		ErrorLogger:            nil,
		IsolationLevel:         0,
		MaxAttempts:            0,
	})
	return &SegmentioConsumer{
		kafkaURLs: kafkaURLs,
		topic:     topic,
		consumer:  reader,
	}, nil
}
NewSegmentioConsumer create new Segmentio Consumer.
package consumer
import (
	"context"
	"github.com/dimmyjr/goku/message"
	"github.com/segmentio/kafka-go"
)
type SegmentioConsumer struct {
	kafkaURLs []string
	topic     string
	consumer  *kafka.Reader
}