Documentation
¶
Index ¶
- type ConsumerGroupOffsetOperation
- func (operation *ConsumerGroupOffsetOperation) CloneConsumerGroup(srcGroup, targetGroup string) error
- 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 OffsetResettingConsumer
- type OffsetSettingConsumer
- type PartitionOffset
- type ResetConsumerGroupOffsetFlags
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 OffsetResettingConsumer ¶
type OffsetResettingConsumer struct {
// contains filtered or unexported fields
}
func (*OffsetResettingConsumer) Cleanup ¶
func (consumer *OffsetResettingConsumer) Cleanup(sarama.ConsumerGroupSession) error
func (*OffsetResettingConsumer) ConsumeClaim ¶
func (consumer *OffsetResettingConsumer) ConsumeClaim(sarama.ConsumerGroupSession, sarama.ConsumerGroupClaim) error
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 (s *OffsetSettingConsumer) Cleanup(sarama.ConsumerGroupSession) error
func (*OffsetSettingConsumer) ConsumeClaim ¶
func (s *OffsetSettingConsumer) ConsumeClaim(sarama.ConsumerGroupSession, sarama.ConsumerGroupClaim) error
func (*OffsetSettingConsumer) Setup ¶
func (s *OffsetSettingConsumer) Setup(session sarama.ConsumerGroupSession) error
type PartitionOffset ¶
Click to show internal directories.
Click to hide internal directories.