kafkaingest

Documentation

Index

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

Functions

func KafkaProducerGroup

func KafkaProducerGroup(ctx context.Context, producer *kafka.Producer, logger *slog.Logger) (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.

type NamespaceHandler

type NamespaceHandler = kafkaingest.NamespaceHandler

NamespaceHandler is a namespace handler for Kafka ingest topics.