consumer_helper

Documentation

Index

• func CreateRetryConsumer(config RetryConsumerConfig) (*consumer.RetryConsumer, error)
• type RetryConsumerConfig
  • func NewDefaultConfig(bootstrapServers string, topics []string, groupID string) RetryConsumerConfig

Functions

func CreateRetryConsumer

func CreateRetryConsumer(config RetryConsumerConfig) (*consumer.RetryConsumer, error)

CreateRetryConsumer crea un RetryConsumer con un productor predeterminado integrado Esta función facilita la creación de un RetryConsumer sin tener que manejar manualmente la creación y configuración del productor de reintentos necesario

Types

type RetryConsumerConfig

type RetryConsumerConfig struct {
	// Parámetros obligatorios
	BootstrapServers string
	Topics           []string
	GroupID          string

	// Parámetros opcionales con valores predeterminados
	RetryInterval    int
	MaxRetries       int
	AutoOffsetReset  consumer_types.AutoOffsetReset
	EnableAutoCommit bool
	ClientID         string
}

RetryConsumerConfig contiene la configuración simplificada para crear un RetryConsumer

func NewDefaultConfig

func NewDefaultConfig(bootstrapServers string, topics []string, groupID string) RetryConsumerConfig

NewDefaultConfig crea una configuración por defecto con valores razonables