consumergroupoffsets

package
v5.0.6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 14, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ConsumerGroupOffsetOperation

type ConsumerGroupOffsetOperation struct {
}

func (*ConsumerGroupOffsetOperation) CloneConsumerGroup

func (operation *ConsumerGroupOffsetOperation) CloneConsumerGroup(srcGroup, targetGroup string) error

func (*ConsumerGroupOffsetOperation) CreateConsumerGroup

func (operation *ConsumerGroupOffsetOperation) CreateConsumerGroup(flags ResetConsumerGroupOffsetFlags, group string) error

func (*ConsumerGroupOffsetOperation) DeleteConsumerGroupOffset

func (operation *ConsumerGroupOffsetOperation) DeleteConsumerGroupOffset(groupName string, flags DeleteConsumerGroupOffsetFlags) error

func (*ConsumerGroupOffsetOperation) ResetConsumerGroupOffset

func (operation *ConsumerGroupOffsetOperation) ResetConsumerGroupOffset(flags ResetConsumerGroupOffsetFlags, groupName string) error

type DeleteConsumerGroupOffsetFlags

type DeleteConsumerGroupOffsetFlags struct {
	Topic     string
	Partition int32
}

type OffsetResettingConsumer

type OffsetResettingConsumer struct {
	// contains filtered or unexported fields
}

func (*OffsetResettingConsumer) Cleanup

func (*OffsetResettingConsumer) ConsumeClaim

func (*OffsetResettingConsumer) Setup

func (consumer *OffsetResettingConsumer) Setup(session sarama.ConsumerGroupSession) error

type OffsetSettingConsumer

type OffsetSettingConsumer struct {
	Topic            string
	PartitionOffsets map[int32]PartitionOffset
	// contains filtered or unexported fields
}

func (*OffsetSettingConsumer) Cleanup

func (*OffsetSettingConsumer) ConsumeClaim

func (*OffsetSettingConsumer) Setup

type PartitionOffset

type PartitionOffset struct {
	Offset   int64
	Metadata string
}

type ResetConsumerGroupOffsetFlags

type ResetConsumerGroupOffsetFlags struct {
	Topic        []string
	AllTopics    bool
	Partition    int32
	Offset       int64
	OldestOffset bool
	NewestOffset bool
	Execute      bool
	OutputFormat string

	ToDatetime string
	// contains filtered or unexported fields
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL