package
0.0.0-20240508035004-fd7de3346cfe
Repository: https://github.com/ecodeclub/mq-api.git
Documentation: pkg.go.dev

# Packages

No description provided by the author
No description provided by the author

# Functions

No description provided by the author
No description provided by the author

# Constants

CloseEvent consumer_group=>consumer 表示消费组关闭所有消费者,向所有消费者发出关闭事件.
ExitGroupEvent consumer=>consumer_group 表示消费者退出消费组的事件.
PartitionNotifyAckEvent consumer=>consumer_group 表示消费者对消费组下发分区情况事件的确认.
PartitionNotifyEvent consumer_group=>consumer 表示消费组向消费者下发分区情况.
RejoinAckEvent consumer=>consumer_group 表示消费者收到重新加入消费组的指令并将offset进行上报.
RejoinEvent consumer_group=>consumer 表示消费组通知消费者重新加入消费组.
ReportOffsetEvent consumer=>consumer_group 表示消费者向消费组上报消费进度事件.
No description provided by the author
稳定状态,可以正常的进行消费数据.
消费组关闭.
一个消费者正在退出消费组.

# Variables

No description provided by the author
No description provided by the author

# Structs

No description provided by the author
ConsumerGroup 表示消费组是并发安全的.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author

# Interfaces

ConsumerPartitionAssigner 此抽象是给消费组使用,用于将分区分配给消费组内的消费者。.
PartitionIDGetter 此抽象用于Producer获取对应分区号.