OffsetCommit

Documentation

Index

• func NewRequest(group, topic string, partition int32, offset, retentionMs int64) *api.Request
• type Partition
• type PartitionResponse
• type Request
• type Response
• type Topic
• type TopicResponse

Functions

func NewRequest

func NewRequest(group, topic string, partition int32, offset, retentionMs int64) *api.Request

Types

type Partition

type Partition struct {
	PartitionIndex   int32
	CommitedOffset   int64
	CommitedMetadata string
}

type PartitionResponse

type PartitionResponse struct {
	PartitionIndex int32
	ErrorCode      int16
}

type Request

type Request struct {
	GroupId         string
	GenerationId    int32
	MemberId        string
	RetentionTimeMs int64
	Topics          []Topic
}

type Response

type Response struct {
	Topics []TopicResponse
}

type Topic

type Topic struct {
	Name       string
	Partitions []Partition
}

type TopicResponse

type TopicResponse struct {
	Name       string
	Partitions []PartitionResponse
}