Versions in this module Expand all Collapse all v1 v1.0.0 Mar 28, 2023 Changes in this version + const OwnerName + const PeerProxyID + const SemanticAtLeastOnce + const SemanticAtMostOnce + var ErrGroupNotAllowACK = errors.New("consumer group is not allowed to be acknowledged") + var ErrGroupNotFound = errors.New("consumer group not found") + var ErrGroupStopped = errors.New("consumer group was stopped") + var ErrNoMessage = errors.New("no message in brokers") + var ErrNoPartition = errors.New("consumer group doesn't claim any partition") + var ErrNoPeer = errors.New("no peer can pull message") + var ErrTopicNotFound = errors.New("topic not found in this consumer group") + var ErrUnackManagerStopped = errors.New("unack manager was stopped") + var ErrUnackMessageNotFound = errors.New("unack message not found") + type Consumer struct + Puller *Puller + func NewConsumer(saramaClient sarama.Client, conf *config.Config) (*Consumer, error) + func (c *Consumer) ACK(token, group, topic string, partition int32, offset int64) error + func (c *Consumer) Consume(group, topic string, timeout, ttr time.Duration) (message *sarama.ConsumerMessage, err error) + func (c *Consumer) Export(group string) (map[string]interface{}, error) + func (c *Consumer) GetConsumerGroup(group string) *consumerGroup + func (c *Consumer) GetConsumerGroupState(group string) (string, error) + func (c *Consumer) GetMetadataByName(group string) *GroupMetadata + func (c *Consumer) ListConsumerGroup() []string + func (c *Consumer) ReleaseConsumerGroups() + func (c *Consumer) Start() error + func (c *Consumer) Stop() + func (c *Consumer) UpdateConsumerGroupState(group string, stopped bool) error + type GroupMetadata struct + Consumer config.ConsumerConfig + Owner string + Semantics string + Stopped bool + Topics []string + type Puller struct + func (p *Puller) Close() error + func (p *Puller) PullFromPeers(group, topic, token string, timeout, ttr uint64, noPartition bool) (*sarama.ConsumerMessage, error) + func (p *Puller) Start() error + type TopicUnackManager struct
Go to main page