config

type Config struct {
	Server ServerConfig `mapstructure:"server"`
	Kafka  KafkaConfig  `mapstructure:"kafka"`
}

type KafkaConfig struct {
	BootstrapServers string              `mapstructure:"bootstrap-servers"`
	MaxRetries       int                 `mapstructure:"max-retries"`
	ProducerConfig   KafkaProducerConfig `mapstructure:"producer"`
	ConsumerConfig   KafkaConsumerConfig `mapstructure:"consumer"`
}

type KafkaConsumerConfig struct {
	EmailTopic           string `mapstructure:"email-topic"`
	MessageChannelBuffer int    `mapstructure:"message-channel-buffer"`
	AutoCommitInterval   int    `mapstructure:"auto-commit-interval"`
	WorkerPool           int    `mapstructure:"worker-pool"`
	GroupID              string `mapstructure:"group-id"`
	DeadLetterTopic      string `mapstructure:"dead-letter-topic"`
}

type KafkaProducerConfig struct {
	BootstrapServers     string `mapstructure:"bootstrap-servers"`
	RequiredAcks         int    `mapstructure:"required-acks"`
	MessageChannelBuffer int    `mapstructure:"message-channel-buffer"`
	WorkerPool           int    `mapstructure:"worker-pool"`
	BatchSize            int    `mapstructure:"batch-size"`
	BatchTimeoutMs       int    `mapstructure:"batch-timeout-ms"`
}

type ServerConfig struct {
	Port string
}