kafka

Documentation

Overview

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

Index

• func NewReporter(address []string, options ...ReporterOption) (reporter.Reporter, error)
• type ReporterOption
  • func Logger(logger *log.Logger) ReporterOption
  • func Producer(p sarama.AsyncProducer) ReporterOption
  • func Serializer(serializer reporter.SpanSerializer) ReporterOption
  • func Topic(t string) ReporterOption

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

func Producer(p sarama.AsyncProducer) ReporterOption

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

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.