From 098af91821d4cd026fc9c41e10b9d226f02c8565 Mon Sep 17 00:00:00 2001 From: Aiwantaozi Date: Wed, 23 Jan 2019 08:55:32 +0800 Subject: [PATCH] Add logging kafka sasl support Problem: Need add sasl support for kafka in logging Solution: Add plain and scram kafka sasl support Issue: https://github.com/rancher/rancher/issues/16614 --- apis/management.cattle.io/v3/logging_types.go | 16 ++++++++++------ 1 file changed, 10 insertions(+), 6 deletions(-) diff --git a/apis/management.cattle.io/v3/logging_types.go b/apis/management.cattle.io/v3/logging_types.go index 812975ff..4ff8bca6 100644 --- a/apis/management.cattle.io/v3/logging_types.go +++ b/apis/management.cattle.io/v3/logging_types.go @@ -123,12 +123,16 @@ type SplunkConfig struct { } type KafkaConfig struct { - ZookeeperEndpoint string `json:"zookeeperEndpoint,omitempty"` - BrokerEndpoints []string `json:"brokerEndpoints,omitempty"` - Topic string `json:"topic,omitempty" norman:"required"` - Certificate string `json:"certificate,omitempty"` - ClientCert string `json:"clientCert,omitempty"` - ClientKey string `json:"clientKey,omitempty"` + ZookeeperEndpoint string `json:"zookeeperEndpoint,omitempty"` + BrokerEndpoints []string `json:"brokerEndpoints,omitempty"` + Topic string `json:"topic,omitempty" norman:"required"` + Certificate string `json:"certificate,omitempty"` + ClientCert string `json:"clientCert,omitempty"` + ClientKey string `json:"clientKey,omitempty"` + SaslUsername string `json:"saslUsername,omitempty"` + SaslPassword string `json:"saslPassword,omitempty" norman:"type=password"` + SaslScramMechanism string `json:"saslScramMechanism,omitempty" norman:"type=enum,options=sha256|sha512"` + SaslType string `json:"saslType,omitempty" norman:"type=enum,options=plain|scram"` } type SyslogConfig struct {