kafka

Documentation

Index

• func New(ctx context.Context, cfg config.Producer, lg *zap.Logger, ...) producer.Producer
• type Kafka
  • func (k *Kafka) Start()

Functions

func New

func New(ctx context.Context, cfg config.Producer, lg *zap.Logger, inChan telemetry.ExtDSChan) producer.Producer

New constructs an instance of kafka producer.

Types

type Kafka

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

Kafka represents Kafka Segment.io

func (*Kafka) Start

func (k *Kafka) Start()

Start sends the data to the different topics (fan-out).