kafka

Documentation

Index

• func NewKafkaProducer(cfg *config.AppConfig) (interfaces.KafkaService, error)
• type KafkaProducer
  • func (p *KafkaProducer) Close() error
  • func (p *KafkaProducer) Produce(ctx context.Context, key, value []byte) error

Functions

func NewKafkaProducer

func NewKafkaProducer(cfg *config.AppConfig) (interfaces.KafkaService, error)

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

Types

type KafkaProducer

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

func (*KafkaProducer) Close

func (p *KafkaProducer) Close() error

Close закрывает соединение с Kafka

func (*KafkaProducer) Produce

func (p *KafkaProducer) Produce(ctx context.Context, key, value []byte) error

Produce отправляет сообщение в Kafka