kafka

Documentation

Index

• type Consumer
  • func NewConsumer(rawConfig string) (*Consumer, error)
  • func (c *Consumer) Description() string
  • func (c *Consumer) Instance() component.Instance
  • func (c *Consumer) SampleConfig() string
  • func (c *Consumer) Start() error
  • func (c *Consumer) Stop() error
• type ConsumerConfig
• type Producer
  • func NewProducer(rawConfig string) (*Producer, error)
  • func (c *Producer) Description() string
  • func (c *Producer) Instance() component.Instance
  • func (c *Producer) SampleConfig() string
  • func (c *Producer) Start() error
  • func (c *Producer) Stop() error
• type ProducerConfig

Types

type Consumer

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

func NewConsumer

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

func (*Consumer) Description

func (c *Consumer) Description() string

Description returns a one-sentence description on the Input

func (*Consumer) Instance

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

func (*Consumer) SampleConfig

func (c *Consumer) SampleConfig() string

SampleConfig returns the default configuration of the Input

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"`
}

type Producer

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

func NewProducer

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

func (*Producer) Description

func (c *Producer) Description() string

Description returns a one-sentence description on the Input

func (*Producer) Instance

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

func (*Producer) SampleConfig

func (c *Producer) SampleConfig() string

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"`
}