kafkacommon

type Broker interface {
	Write(ctx context.Context, messages []kafka.Message) error
}

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

type Config struct {
	Addresses               []string      `env:"ADDRESSES" yaml:"addresses"`
	WriteTopic              string        `env:"WRITE_TOPIC" yaml:"write_topic"`
	WriteBatchSize          int           `env:"WRITE_BATCH_SIZE" yaml:"write_batch_size"`
	WriteBatchTimeout       time.Duration `env:"WRITE_BATCH_TIMEOUT" yaml:"write_batch_timeout"`
	WriteMaxRetryCount      uint64        `env:"WRITE_MAX_RETRY_COUNT" yaml:"write_max_retry_count"`
	WriteRetryJitterPercent uint64        `env:"WRITE_RETRY_JITTER_PERCENT" yaml:"write_retry_jitter_percent"`
	WriteRetryTimeout       time.Duration `env:"WRITE_RETRY_TIMEOUT" yaml:"write_retry_timeout"`
}