kafka

Documentation

Overview

Copyright The OpenTelemetry Authors SPDX-License-Identifier: Apache-2.0

Copyright The OpenTelemetry Authors SPDX-License-Identifier: Apache-2.0

Index

• Variables
• func StartConsumerGroup(ctx context.Context, brokers []string, log *logrus.Logger) (sarama.ConsumerGroup, error)
• type OTelInterceptor
  • func NewOTelInterceptor(groupID string) *OTelInterceptor
  • func (oi *OTelInterceptor) OnConsume(msg *sarama.ConsumerMessage)

Variables

var (
	Topic           = "orders"
	ProtocolVersion = sarama.V3_0_0_0
	GroupID         = "accountingservice"
)

Functions

func StartConsumerGroup

func StartConsumerGroup(ctx context.Context, brokers []string, log *logrus.Logger) (sarama.ConsumerGroup, error)

Types

type OTelInterceptor

type OTelInterceptor struct {
	// contains filtered or unexported fields
}

func NewOTelInterceptor

func NewOTelInterceptor(groupID string) *OTelInterceptor

NewOTelInterceptor processes span for intercepted messages and add some headers with the span data.

func (*OTelInterceptor) OnConsume

func (oi *OTelInterceptor) OnConsume(msg *sarama.ConsumerMessage)