watcher

Documentation

Index

• type Record
• type Watcher
  • func New(brokers, topics []string, consumerGroup string) (*Watcher, error)
  • func (w *Watcher) ConsumeRecords(matches func(message *message.Message) bool)
  • func (w *Watcher) StartTaskHandler(taskHandler func(*message.Message) error)

Types

type Record

type Record struct {
	*kgo.Record
}

type Watcher

type Watcher struct {
	// Ensure Client is closed to preserve proper state in partitions
	//
	// defer watcher.Client.Close()
	Client *kgo.Client
	// contains filtered or unexported fields
}

func New

func New(brokers, topics []string, consumerGroup string) (*Watcher, error)

New returns a new Watcher

func (*Watcher) ConsumeRecords

func (w *Watcher) ConsumeRecords(matches func(message *message.Message) bool)

ConsumeRecords returns matches of record results

func (*Watcher) StartTaskHandler

func (w *Watcher) StartTaskHandler(taskHandler func(*message.Message) error)

StartTaskHandler returns nil