kafka

Documentation

Index

• type KafkaInput
  • func (this *KafkaInput) Ack(pack *engine.Packet) error
  • func (this *KafkaInput) End(r engine.InputRunner)
  • func (this *KafkaInput) Init(config *conf.Conf)
  • func (this *KafkaInput) Run(r engine.InputRunner, h engine.PluginHelper) error
  • func (*KafkaInput) SampleConfig() string

Types

type KafkaInput

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

KafkaInput is an input plugin that consumes data stream from a single specified kafka topic.

func (*KafkaInput) Ack

func (this *KafkaInput) Ack(pack *engine.Packet) error

func (*KafkaInput) End

func (this *KafkaInput) End(r engine.InputRunner)

func (*KafkaInput) Init

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

func (*KafkaInput) Run

func (this *KafkaInput) Run(r engine.InputRunner, h engine.PluginHelper) error

func (*KafkaInput) SampleConfig

func (*KafkaInput) SampleConfig() string