consumergroupoffsets

Documentation

Index

• type Consumer
  • func (consumer *Consumer) Cleanup(sarama.ConsumerGroupSession) error
  • func (consumer *Consumer) ConsumeClaim(sarama.ConsumerGroupSession, sarama.ConsumerGroupClaim) error
  • func (consumer *Consumer) Setup(session sarama.ConsumerGroupSession) error
• type ConsumerGroupOffsetOperation
  • func (operation *ConsumerGroupOffsetOperation) CreateConsumerGroup(flags ResetConsumerGroupOffsetFlags, group string) error
  • func (operation *ConsumerGroupOffsetOperation) DeleteConsumerGroupOffset(groupName string, flags DeleteConsumerGroupOffsetFlags) error
  • func (operation *ConsumerGroupOffsetOperation) ResetConsumerGroupOffset(flags ResetConsumerGroupOffsetFlags, groupName string) error
• type DeleteConsumerGroupOffsetFlags
• type ResetConsumerGroupOffsetFlags

Types

type Consumer

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

func (*Consumer) Cleanup

func (consumer *Consumer) Cleanup(sarama.ConsumerGroupSession) error

func (*Consumer) ConsumeClaim

func (consumer *Consumer) ConsumeClaim(sarama.ConsumerGroupSession, sarama.ConsumerGroupClaim) error

func (*Consumer) Setup

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

type ConsumerGroupOffsetOperation

type ConsumerGroupOffsetOperation struct {
}

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 ResetConsumerGroupOffsetFlags

type ResetConsumerGroupOffsetFlags struct {
	Topic        string
	Partition    int32
	Offset       int64
	OldestOffset bool
	NewestOffset bool
	Execute      bool
	OutputFormat string
	// contains filtered or unexported fields
}