kafkaingest

Documentation

Index

• func KafkaProducerGroup(ctx context.Context, producer *kafka.Producer, logger *slog.Logger, ...) (execute func() error, interrupt func(error))
• type Collector
  • func NewCollector(producer *kafka.Producer, serializer serializer.Serializer, ...) (*Collector, error)
• type NamespaceHandler

Functions

func KafkaProducerGroup

func KafkaProducerGroup(ctx context.Context, producer *kafka.Producer, logger *slog.Logger, kafkaMetrics *kafkametrics.Metrics) (execute func() error, interrupt func(error))

Types

type Collector

type Collector = kafkaingest.Collector

Collector is a receiver of events that handles sending those events to a downstream Kafka broker.

func NewCollector

func NewCollector(
	producer *kafka.Producer,
	serializer serializer.Serializer,
	namespacedTopicTemplate string,
	metricMeter metric.Meter,
) (*Collector, error)

type NamespaceHandler

type NamespaceHandler = kafkaingest.NamespaceHandler

NamespaceHandler is a namespace handler for Kafka ingest topics.