diff --git a/flyteadmin/pkg/runtime/interfaces/application_configuration.go b/flyteadmin/pkg/runtime/interfaces/application_configuration.go index 86bb9d30f6..809aadb941 100644 --- a/flyteadmin/pkg/runtime/interfaces/application_configuration.go +++ b/flyteadmin/pkg/runtime/interfaces/application_configuration.go @@ -236,21 +236,32 @@ type GCPConfig struct { ProjectID string `json:"projectId"` } +// This section holds SASL config for Kafka type SASLConfig struct { - Enabled bool `json:"enabled"` - User string `json:"user"` - Password string `json:"password"` - Handshake bool `json:"handshake"` + // Whether to use SASL + Enabled bool `json:"enabled"` + // The username + User string `json:"user"` + // The password + Password string `json:"password"` + Handshake bool `json:"handshake"` + // Which SASL Mechanism to use. Defaults to PLAIN Mechanism sarama.SASLMechanism `json:"mechanism"` } +// This section holds TLS config for Kafka clients type TLSConfig struct { - Enabled bool `json:"enabled"` - InsecureSkipVerify bool `json:"insecureSkipVerify"` - CertPath string `json:"certPath"` - KeyPath string `json:"keyPath"` + // Whether to use TLS + Enabled bool `json:"enabled"` + // Whether to skip certificate verification + InsecureSkipVerify bool `json:"insecureSkipVerify"` + // The location of the client certificate + CertPath string `json:"certPath"` + // The location of the client private key + KeyPath string `json:"keyPath"` } +// This section holds configs for Kafka clients type KafkaConfig struct { // The version of Kafka, e.g. 2.1.0, 0.8.2.0 Version string `json:"version"`