kafka

type ConsumerGroup struct {
	// a consumer group for Kafka topic
	GroupID string
	//  If is OK, representing auto commit.
	OffsetsAutoCommitEnable bool
	// flow control batch number for Kafka consumer group
	FlowControlBatchNum int
	// initial offset timeout for Kafka consumer group
	InitOffsetGetOffsetTimeout int64
	// initial offset period for Kafka consumer group
	InitOffsetGetOffsetPeroid int64

	// event handler
	Event *event.Event
	// redis pool
	RedisPool *redis.Pool
	//  a consumer group for Kafka topic
	ConsumerGroup sarama.ConsumerGroup

	// the stop controller of flow control
	StopWg sync.WaitGroup
	// contains filtered or unexported fields
}

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

type Msg struct {
	Message *sarama.ConsumerMessage
}