pubsub

type Config struct {
	Kafka Kafka `mapstructure:"kafka"`
}

type Kafka struct {
	BrokerUrls             []string   `mapstructure:"broker_urls"`
	ClientId               string     `mapstructure:"client_id"`
	Cert                   string     `mapstructure:"cert_pem"`
	CertKey                string     `mapstructure:"cert_pem_key"`
	SecurityProtocol       string     `mapstructure:"security_protocol"`
	Publisher              Publisher  `mapstructure:"publisher"`
	Subscriber             Subscriber `mapstructure:"subscriber"`
	SSLVerificationEnabled bool       `mapstructure:"ssl_verification_enabled"`
}

type Publisher struct {
	MaxAttempts  int           `mapstructure:"max_attempts"`
	WriteTimeout time.Duration `mapstructure:"write_timeout"`
	Topic        string        `mapstructure:"topic"`
	Enabled      bool          `mapstructure:"enabled"`
}

type Subscriber struct {
	Topic   string `mapstructure:"topic"`
	GroupId string `mapstructure:"group_id"`
	Enabled bool   `mapstructure:"enabled"`
}