kafka

Documentation

Index

• type KafkaInput
  • func (self *KafkaInput) Init(pcf *plugins.PluginCommonConfig, conf toml.Primitive) (err error)
  • func (self *KafkaInput) Run(runner plugins.InputRunner) (err error)
• type KafkaInputConfig
• type KafkaOutput
  • func (self *KafkaOutput) Init(pcf *plugins.PluginCommonConfig, conf toml.Primitive) (err error)
  • func (self *KafkaOutput) Run(runner plugins.OutputRunner) (err error)
• type KafkaOutputConfig

Types

type KafkaInput

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

func (*KafkaInput) Init

func (self *KafkaInput) Init(pcf *plugins.PluginCommonConfig, conf toml.Primitive) (err error)

func (*KafkaInput) Run

func (self *KafkaInput) Run(runner plugins.InputRunner) (err error)

type KafkaInputConfig

type KafkaInputConfig struct {
	ClientId      string `toml:"client_id"`
	Addrs         []string
	Partition     int32
	Topic         string
	Partitions    int32
	FlushInterval uint32 `toml:"flush_interval"`
}

type KafkaOutput

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

func (*KafkaOutput) Init

func (self *KafkaOutput) Init(pcf *plugins.PluginCommonConfig, conf toml.Primitive) (err error)

func (*KafkaOutput) Run

func (self *KafkaOutput) Run(runner plugins.OutputRunner) (err error)

type KafkaOutputConfig

type KafkaOutputConfig struct {
	ClientId      string `toml:"client_id"`
	Addrs         []string
	Partition     int32
	Topic         string
	Partitions    int32
	Distributer   string
	FlushInterval uint32 `toml:"flush_interval"`
}