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 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.

func Topic

func Topic(t string) ReporterOption

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