kafka

type Client struct {
	RecvQ         chan sarama.ConsumerMessage
	Producer      sarama.SyncProducer
	ProducerTopic string
	SendQueue     chan deployment.Event
}

type Config struct {
	Enabled      bool     `json:"enabled"`
	Brokers      []string `json:"brokers"`
	Topic        string   `json:"topic"`
	ClientID     string   `json:"client-id"`
	GroupID      string   `json:"group-id"`
	LogVerbosity string   `json:"log-verbosity"`
	TLS          TLS      `json:"tls"`
	SASL         SASL     `json:"sasl"`
}

type SASL struct {
	Enabled   bool   `json:"enabled"`
	Handshake bool   `json:"handshake"`
	Username  string `json:"username"`
	Password  string `json:"password"`
}

type TLS struct {
	Enabled  bool `json:"enabled"`
	Insecure bool `json:"insecure"`
}