kafka

Documentation

Index

• func Config(c *sarama.Config) ec.Option
• func NewCollectorWithConfig(cfg *ec.Config) (ec.EventCollector, error)
• type Collector
  • func NewCollector(opts ...ec.Option) (*Collector, error)
  • func (c *Collector) Close() error
  • func (c *Collector) Collect(e *ec.Event) error
  • func (c *Collector) CollectByTopic(topic string, e *ec.Event) error

Functions

func Config

func Config(c *sarama.Config) ec.Option

Config wraps the sarama kafka configuration

func NewCollectorWithConfig

func NewCollectorWithConfig(cfg *ec.Config) (ec.EventCollector, error)

NewCollectorWithConfig contructs a kafka event collector with `Config`.

Types

type Collector

type Collector struct {
	Client sarama.AsyncProducer
	Topic  string
}

Collector wraps a kafka collector.

func NewCollector

func NewCollector(opts ...ec.Option) (*Collector, error)

NewCollector creates a kafka collector.

func (*Collector) Close

func (c *Collector) Close() error

Close the kafka collector.

func (*Collector) Collect

func (c *Collector) Collect(e *ec.Event) error

Collect send events to kafka.

func (*Collector) CollectByTopic

func (c *Collector) CollectByTopic(topic string, e *ec.Event) error

CollectByTopic send events to kafka by the specified topic.