kafkaproducer

Documentation

Overview

Produces all received flows to Kafka instance. This segment is based on the kafkaconnector library: https://github.com/bwNetFlow/kafkaconnector

Index

• type KafkaProducer
  • func (segment KafkaProducer) New(config map[string]string) segments.Segment
  • func (segment *KafkaProducer) Run(wg *sync.WaitGroup)

Types

type KafkaProducer

type KafkaProducer struct {
	segments.BaseSegment
	Server      string // required
	Topic       string // required
	TopicSuffix string // optional, default is empty
	User        string // required if auth is true
	Pass        string // required if auth is true
	Tls         bool   // optional, default is true
	Auth        bool   // optional, default is true
	// contains filtered or unexported fields
}

FIXME: use sarama directly here

func (KafkaProducer) New

func (segment KafkaProducer) New(config map[string]string) segments.Segment

func (*KafkaProducer) Run

func (segment *KafkaProducer) Run(wg *sync.WaitGroup)