tmq

Documentation

Index

• type Consumer
  • func NewConsumer(conf *tmq.ConfigMap) (*Consumer, error)
  • func (c *Consumer) Assignment() (partitions []tmq.TopicPartition, err error)
  • func (c *Consumer) Close() error
  • func (c *Consumer) Commit() ([]tmq.TopicPartition, error)
  • func (c *Consumer) CommitOffsets(offsets []tmq.TopicPartition) ([]tmq.TopicPartition, error)
  • func (c *Consumer) Committed(partitions []tmq.TopicPartition, timeoutMs int) (offsets []tmq.TopicPartition, err error)
  • func (c *Consumer) Poll(timeoutMs int) tmq.Event
  • func (c *Consumer) Position(partitions []tmq.TopicPartition) (offsets []tmq.TopicPartition, err error)
  • func (c *Consumer) Seek(partition tmq.TopicPartition, ignoredTimeoutMs int) error
  • func (c *Consumer) Subscribe(topic string, rebalanceCb RebalanceCb) error
  • func (c *Consumer) SubscribeTopics(topics []string, rebalanceCb RebalanceCb) error
  • func (c *Consumer) Unsubscribe() error
• type RebalanceCb

Types

type Consumer

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

func NewConsumer

func NewConsumer(conf *tmq.ConfigMap) (*Consumer, error)

NewConsumer Create new TMQ consumer with TMQ config

func (*Consumer) Assignment

func (c *Consumer) Assignment() (partitions []tmq.TopicPartition, err error)

func (*Consumer) Close

func (c *Consumer) Close() error

Close release consumer

func (*Consumer) Commit

func (c *Consumer) Commit() ([]tmq.TopicPartition, error)

func (*Consumer) CommitOffsets

func (c *Consumer) CommitOffsets(offsets []tmq.TopicPartition) ([]tmq.TopicPartition, error)

func (*Consumer) Committed

func (c *Consumer) Committed(partitions []tmq.TopicPartition, timeoutMs int) (offsets []tmq.TopicPartition, err error)

func (*Consumer) Poll

func (c *Consumer) Poll(timeoutMs int) tmq.Event

Poll consumer poll message with timeout

func (*Consumer) Position

func (c *Consumer) Position(partitions []tmq.TopicPartition) (offsets []tmq.TopicPartition, err error)

func (*Consumer) Seek

func (c *Consumer) Seek(partition tmq.TopicPartition, ignoredTimeoutMs int) error

func (*Consumer) Subscribe

func (c *Consumer) Subscribe(topic string, rebalanceCb RebalanceCb) error

func (*Consumer) SubscribeTopics

func (c *Consumer) SubscribeTopics(topics []string, rebalanceCb RebalanceCb) error

func (*Consumer) Unsubscribe

func (c *Consumer) Unsubscribe() error

Unsubscribe TMQ unsubscribe

type RebalanceCb

type RebalanceCb func(*Consumer, tmq.Event) error