package kafka

import "github.com/openzipkin/zipkin-go/reporter/kafka"

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.

Source Files ¶

kafka.go