Versions in this module Expand all Collapse all v1 v1.0.1 Aug 24, 2020 Changes in this version + const MAX_REQ_CNT + const PULL_OFFLINE_WORKER_MSG_NUM_EVERY_TIME + const WORKER_ADDRESS_EXPIRE + func Init(brokerList string, topicPrefix string, centerIp string, rpcPort int64) + func InitKafkaConf(brokerList string, topicPrefix string) *entity.KafkaConfig + type CenterConsumer struct + func (this *CenterConsumer) ConsumerDelayMsg(req message.Request, res *message.Response) error + type Consumer struct + func (consumer *Consumer) Cleanup(sarama.ConsumerGroupSession) error + func (consumer *Consumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error + func (consumer *Consumer) Setup(sarama.ConsumerGroupSession) error + type ICenterService interface + Start func() + Stop func() + var CenterService ICenterService + func NewCenterService(brokerList string, topicPrefix string, rpcPort int64, centerIp string) ICenterService