kafka

Documentation

Index

• func CloseConsumer(service ConsumerService)
• func CloseProducer(service ProducerService)
• func SendMessageToRecommender(service ProducerService, event any, topic string) error
• func StartEventsConsumer(ctx context.Context, service ConsumerService, topic string, ...) error
• type ConsumerService
• type ProducerService

Functions

func CloseConsumer

func CloseConsumer(service ConsumerService)

func CloseProducer

func CloseProducer(service ProducerService)

func SendMessageToRecommender

func SendMessageToRecommender(service ProducerService, event any, topic string) error

func StartEventsConsumer

func StartEventsConsumer(ctx context.Context, service ConsumerService, topic string, OnEvent func(p int32, pc sarama.PartitionConsumer)) error

StartEventsConsumer starts a simple Kafka consumer that listens to the given topic

Types

type ConsumerService

type ConsumerService interface {
	GetConsumer() sarama.Consumer
}

type ProducerService

type ProducerService interface {
	GetProducer() sarama.AsyncProducer
}