offsets

type ConsumerOffset struct {
	ConsumerGroup  string    `gorm:"column:consumer_group;primary_key"`
	Topic          string    `gorm:"column:topic;primary_key"`
	KafkaPartition int32     `gorm:"column:kafka_partition;primary_key"`
	Offset         int64     `gorm:"column:offset"`
	Ts             time.Time `gorm:"column:ts"`
	Metadata       string    `gorm:"column:metadata"`
}

type OffsetCommitRequest struct {
	ConsumerGroup           string
	ConsumerGroupGeneration int32  // nothing to do
	ConsumerID              string // nothing to do
	RetentionTime           int64  // nothing to do
	// contains filtered or unexported fields
}

type OffsetCommitRequestBlock struct {
	Offset    int64
	Timestamp int64
	Metadata  string
}

type OffsetCommitResponse struct {
	Errors map[string]map[int32]error
}

type OffsetFetchRequest struct {
	ConsumerGroup string
	// contains filtered or unexported fields
}

type OffsetFetchResponse struct {
	Blocks     map[string]map[int32]*OffsetFetchResponseBlock
	LastUpdate time.Time //only for db position store
}

type OffsetFetchResponseBlock struct {
	Offset   int64
	Metadata string
	Err      error
}