Documentation ¶
Index ¶
- Variables
- type C
- func (c *C) Commit(topic string, partition int32, consumerGroup string, offset int64) error
- func (c *C) Consume(topic string, partition int32, offset int64) (messages []Message, err error)
- func (c *C) FetchOffsetByTime(topic string, partition int32, keyTime time.Time) (int64, error)
- func (c *C) Offset(topic string, partition int32, consumerGroup string) (int64, error)
- func (c *C) SearchOffsetByTime(topic string, partition int32, keyTime time.Time, getTime proto.GetTimeFunc) (int64, error)
- type Message
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrOffsetNotFound = errors.New("offset not found") ErrFailToFetchOffsetByTime = errors.New("fail to fetch offset by time") )
Functions ¶
This section is empty.
Types ¶
Click to show internal directories.
Click to hide internal directories.