kafka

package module

v0.0.0-...-7af37e1 Latest Latest Go to latest Published: Jan 2, 2025 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type KafkaConfig struct {
	Brokers []string
	Topic   string
	GroupID string // Used for consumers
}

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

func NewConsumer(config KafkaConfig) *KafkaConsumer

NewConsumer creates a new KafkaConsumer instance.

func (c *KafkaConsumer) Close() error

Close closes the Kafka consumer.

func (c *KafkaConsumer) Consume(ctx context.Context, handler func(key, value []byte) error)

Consume starts consuming messages and calls the handler for each message.

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

func NewProducer(config KafkaConfig) *KafkaProducer

NewProducer creates a new KafkaProducer instance.

func (p *KafkaProducer) Close() error

Close closes the Kafka producer.

func (p *KafkaProducer) Publish(ctx context.Context, event *events.Event) error

Publish sends a message to the Kafka topic.