kafka

package
v0.4.3 Latest Latest
Warning

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

Go to latest
Published: Apr 29, 2024 License: Apache-2.0 Imports: 5 Imported by: 10

Documentation

Overview

Package kafka implements a Kafka reporter to send spans to a Kafka server/cluster.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewReporter

func NewReporter(address []string, options ...ReporterOption) (reporter.Reporter, error)

NewReporter returns a new Kafka-backed Reporter. address should be a slice of TCP endpoints of the form "host:port".

Types

type ReporterOption

type ReporterOption func(c *kafkaReporter)

ReporterOption sets a parameter for the kafkaReporter

func Logger

func Logger(logger *log.Logger) ReporterOption

Logger sets the logger used to report errors in the collection process.

func Producer

Producer sets the producer used to produce to Kafka. For tweaking the reporting settings (e.g. reporting timeout or authentication) check the sarama.Config struct.

func Serializer added in v0.1.6

func Serializer(serializer reporter.SpanSerializer) ReporterOption

Serializer sets the serialization function to use for sending span data to Zipkin.

func Topic

func Topic(t string) ReporterOption

Topic sets the kafka topic to attach the reporter producer on.

Jump to

Keyboard shortcuts

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