kafka

Documentation

Index

• type KafkaOutput
  • func (this *KafkaOutput) CleanupForRestart() bool
  • func (this *KafkaOutput) Init(config *conf.Conf)
  • func (this *KafkaOutput) Run(r engine.OutputRunner, h engine.PluginHelper) error
  • func (*KafkaOutput) SampleConfig() string

Types

type KafkaOutput

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

KafkaOutput is an Output plugin that send pack to a single specified kafka topic.

func (*KafkaOutput) CleanupForRestart

func (this *KafkaOutput) CleanupForRestart() bool

func (*KafkaOutput) Init

func (this *KafkaOutput) Init(config *conf.Conf)

Init setup KafkaOutput state according to config section. Default kafka delivery: async WaitForAll.

func (*KafkaOutput) Run

func (this *KafkaOutput) Run(r engine.OutputRunner, h engine.PluginHelper) error

func (*KafkaOutput) SampleConfig

func (*KafkaOutput) SampleConfig() string