broker

Documentation

Index

• func NewKafkaConsumer(brokers, groupID, topic string) (*kafka.Consumer, error)
• func NewKafkaProducer(cfg *config.KafkaConfig) (*kafka.Producer, error)
• type Producer
  • func NewProducer(producer *kafka.Producer, topic string) *Producer
  • func (p *Producer) SendCacheEvent(event domain.EventInvalidateCache) error
  • func (p *Producer) StartErrorLogger(ctx context.Context)

Functions

func NewKafkaConsumer

func NewKafkaConsumer(brokers, groupID, topic string) (*kafka.Consumer, error)

NewKafkaConsumer создает новый экземпляр Kafka Consumer

func NewKafkaProducer

func NewKafkaProducer(cfg *config.KafkaConfig) (*kafka.Producer, error)

Types

type Producer

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

func NewProducer

func NewProducer(producer *kafka.Producer, topic string) *Producer

func (*Producer) SendCacheEvent

func (p *Producer) SendCacheEvent(event domain.EventInvalidateCache) error

func (*Producer) StartErrorLogger

func (p *Producer) StartErrorLogger(ctx context.Context)