topic

Documentation

Index

• type OffsetMovedEvent
  • func NewOffsetMovedEvent() *OffsetMovedEvent

Types

type OffsetMovedEvent

type OffsetMovedEvent struct {
	ConsumerGroup string               `json:"consumerGroup"` // 消费组名称
	MessageQueue  message.MessageQueue `json:"messageQueue"`  // 消息Queue
	OffsetRequest int64                `json:"offsetRequest"` // 客户端请求的Offset
	OffsetNew     int64                `json:"offsetNew"`     // Broker要求从这个新的Offset开始消费
	*protocol.RemotingSerializable
}

func NewOffsetMovedEvent

func NewOffsetMovedEvent() *OffsetMovedEvent