kafka

type Consumer struct {
	WG            sync.WaitGroup
	Topic         string
	PartitionList []int32
	Consumer      sarama.Consumer
	// contains filtered or unexported fields
}

type MConsumerGroup struct {
	sarama.ConsumerGroup
	// contains filtered or unexported fields
}

type MConsumerGroupConfig struct {
	KafkaVersion   sarama.KafkaVersion
	OffsetsInitial int64
	IsReturnErr    bool
}

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