kafka_zipkin_interceptor

README

kafka-zipkin-interceptor

Kafka zipkin interceptor

Documentation

Index

• Variables
• func ExtractTraceInfo(m kafka.Message, key string, topic string, clientId string, groupId string, ...) zipkin.Span
• func WrapInSpan(key string, topic string, clientId string, groupId string, ctx context.Context, ...) ([]kafka.Header, context.Context)

Variables

var (
	REMOTE_SERVICE_NAME_DEFAULT = "kafka"
	KAFKA_TOPIC                 = "kafka.topic"
	KAFKA_KEY                   = "kafka.key"
	KAFKA_CLIENT_ID             = "kafka.client.id"
	KAFKA_GROUP_ID              = "kafka.group.id"
	SPAN_NAME_SEND              = "send"
	SPAN_NAME_POLL              = "poll"
)

Functions

func ExtractTraceInfo

func ExtractTraceInfo(m kafka.Message, key string, topic string, clientId string, groupId string, t *zipkin.Tracer) zipkin.Span

func WrapInSpan

func WrapInSpan(key string, topic string, clientId string, groupId string, ctx context.Context, t *zipkin.Tracer) ([]kafka.Header, context.Context)