config

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

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

type NotificationConfig struct {
	ChannelTopics   map[string]string `mapstructure:"channel-topics"`
	DeadLetterTopic string            `mapstructure:"dead-letter-topic"`
	IsProduceAsync  bool              `mapstructure:"is-produce-async"`
}

type ServerConfig struct {
	Port string
}