kafka

Documentation

Index

• Variables
• func Shutdown()
• func WriteToKafka(event events.Event) error
• type KafkaWriter

Variables

var (
	MessagesSent = promauto.NewCounter(prometheus.CounterOpts{
		Name: "kafka_messages_sent_total",
		Help: "The total number of messages sent",
	})
	SendErrors = promauto.NewCounter(prometheus.CounterOpts{
		Name: "kafka_send_errors_total",
		Help: "The total number of send errors",
	})
)

Initialize Prometheus metrics

Functions

func Shutdown

func Shutdown()

func WriteToKafka

func WriteToKafka(event events.Event) error

WriteToKafka writes the event to Kafka

Types

type KafkaWriter

type KafkaWriter interface {
	WriteMessages(context.Context, ...kafka.Message) error
	Close() error
}

KafkaWriter is an interface that allows for writing messages to Kafka