Versions in this module Expand all Collapse all v2 v2.1.1 Feb 14, 2023 v2.1.0 Feb 14, 2023 Changes in this version + var ErrBrokerNotFound = errors.New("broker can not found") + var ErrCompressLevel = errors.New("unsupported compress level") + var ErrCreated = errors.New("consumer group has been created") + var ErrEmptyExpression = errors.New("empty expression") + var ErrEmptyGroupID = errors.New("empty group id") + var ErrEmptyNameSrv = errors.New("empty namesrv") + var ErrEmptyTopic = errors.New("empty topic") + var ErrIllegalIP = errors.New("IP addr error") + var ErrMQEmpty = errors.New("MessageQueue is nil") + var ErrMessageBody = errors.New("message body size must be positive integer") + var ErrMessageEmpty = errors.New("message is nil") + var ErrMultiIP = errors.New("multiple IP addr does not support") + var ErrMultipleTopics = errors.New("the topic of the messages in one batch should be the same") + var ErrNoNameserver = errors.New("nameServerAddrs can't be empty.") + var ErrNotExisted = errors.New("not existed") + var ErrNotRunning = errors.New("producer not started") + var ErrNumbers = errors.New("numbers < 0") + var ErrOffset = errors.New("offset < 0") + var ErrOperationInterval = errors.New("operation interval must be positive integer") + var ErrProducerCreated = errors.New("producer group has been created") + var ErrPullConsumer = errors.New("pull consumer has not supported") + var ErrRequestTimeout = errors.New("request timeout") + var ErrResponse = errors.New("response error") + var ErrService = errors.New("service close is not running, please check") + var ErrStartTopic = errors.New(...) + var ErrTestMin = errors.New("test minutes must be positive integer") + var ErrTopicEmpty = errors.New("topic is nil") + var ErrTopicNotExist = errors.New("topic not exist") + var ErrUnknownIP = errors.New("unknown IP address")