kafka

type Config struct {
	KafkaUrl               string
	ConsumerGroup          string           //optional
	StartOffset            int64            //defaults to FirstOffset
	Debug                  bool             //defaults to false
	TimeNow                func() time.Time //defaults to time.Now
	Wg                     *sync.WaitGroup  //optional
	PartitionWatchInterval time.Duration    //defaults to time.Minute
	OnError                func(error)      //defaults to log.Fatal
}

type KeySeparationBalancer struct {
	SubBalancer kafka.Balancer
	Seperator   string
}

type Message struct {
	Topic     string
	Partition int
	Offset    int64
	Key       []byte
	Value     []byte
	Time      time.Time
}

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