kafkaproducer

package
v1.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 13, 2023 License: GPL-3.0 Imports: 12 Imported by: 0

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL