kafka

Documentation

Index

• type KafkaService
  • func NewKafkaService(cfgApplication *config.Config, log logger.Logger) (*KafkaService, error)
  • func (k *KafkaService) Close() error
  • func (k *KafkaService) DeleteMessage(ctx context.Context, receiptHandle string) error
  • func (k *KafkaService) ReceiveMessage(ctx context.Context) ([]model.Message, error)
  • func (k *KafkaService) SendMessage(ctx context.Context, message model.Message) error

Types

type KafkaService

type KafkaService struct {
	Config   *config.Config      // Configuración para el servicio Kafka.
	Producer sarama.SyncProducer // Productor de Kafka para enviar mensajes.
	Consumer sarama.Consumer     // Consumidor de Kafka para recibir mensajes.
	Log      logger.Logger       // Logger para registrar mensajes.
}

KafkaService proporciona métodos para interactuar con Kafka para producir y consumir mensajes.

func NewKafkaService

func NewKafkaService(cfgApplication *config.Config, log logger.Logger) (*KafkaService, error)

NewKafkaService crea una nueva instancia de KafkaService. Inicializa el productor y el consumidor de Kafka en base a la configuración y el logger proporcionados.

func (*KafkaService) Close

func (k *KafkaService) Close() error

Close cierra el productor de Kafka.

func (*KafkaService) DeleteMessage

func (k *KafkaService) DeleteMessage(ctx context.Context, receiptHandle string) error

DeleteMessage registra un mensaje indicando que Kafka no admite la eliminación de mensajes individuales. Los mensajes se eliminan automáticamente según el período de retención.

func (*KafkaService) ReceiveMessage

func (k *KafkaService) ReceiveMessage(ctx context.Context) ([]model.Message, error)

ReceiveMessage recibe mensajes del tema de Kafka especificado en la configuración. Deserializa los mensajes de JSON y registra el resultado.

func (*KafkaService) SendMessage

func (k *KafkaService) SendMessage(ctx context.Context, message model.Message) error

SendMessage envía un mensaje al tema de Kafka especificado en la configuración. Serializa el mensaje a JSON y registra el resultado.