kafka

Documentation

Index

• func NewConsumerFactory() component.Factory
• func NewProducerFactory() component.Factory
• type Consumer
  • func NewConsumer(rawConfig string) (*Consumer, error)
  • func (c *Consumer) Instance() component.Instance
  • func (c *Consumer) Start() error
  • func (c *Consumer) Stop() error
• type ConsumerConfig
  • func (c ConsumerConfig) Marshal() ([]byte, error)
• type Producer
  • func NewProducer(rawConfig string) (*Producer, error)
  • func (c *Producer) Instance() component.Instance
  • func (c *Producer) Start() error
  • func (c *Producer) Stop() error
• type ProducerConfig
  • func (c ProducerConfig) Marshal() ([]byte, error)

Functions

func NewConsumerFactory

func NewConsumerFactory() component.Factory

func NewProducerFactory

func NewProducerFactory() component.Factory

Types

type Consumer

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

func NewConsumer

func NewConsumer(rawConfig string) (*Consumer, error)

func (*Consumer) Instance

func (c *Consumer) Instance() component.Instance

func (*Consumer) Start

func (c *Consumer) Start() error

func (*Consumer) Stop

func (c *Consumer) Stop() error

type ConsumerConfig

type ConsumerConfig struct {
	Name              string   `yaml:"name"`
	Addrs             []string `yaml:"addrs"`
	ConsumerGroup     string   `yaml:"consumer_group"`
	Topics            []string `yaml:"topics"`
	OffsetsInitial    int64    `yaml:"offsets_initial"`
	OffsetsAutoCommit bool     `yaml:"offsets_auto_commit"`
}

func (ConsumerConfig) Marshal

func (c ConsumerConfig) Marshal() ([]byte, error)

type Producer

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

func NewProducer

func NewProducer(rawConfig string) (*Producer, error)

func (*Producer) Instance

func (c *Producer) Instance() component.Instance

func (*Producer) Start

func (c *Producer) Start() error

func (*Producer) Stop

func (c *Producer) Stop() error

type ProducerConfig

type ProducerConfig struct {
	Name  string   `yaml:"name"`
	Addrs []string `yaml:"addrs"`
}

func (ProducerConfig) Marshal

func (c ProducerConfig) Marshal() ([]byte, error)