Skip to content
This repository was archived by the owner on Dec 1, 2018. It is now read-only.

Commit a73e737

Browse files
committed
Clean function name
1 parent 628ecea commit a73e737

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

common/kafka/kafka.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -170,8 +170,8 @@ func getSASLConfiguration(opts url.Values) (string, string, bool, error) {
170170
return user, password, true, nil
171171
}
172172

173-
// usageKafkaclient return sink options with *** for password option.
174-
func usageKafkaclient(values url.Values) string {
173+
// getOptionsWithoutSecrets return sink options with *** for secret options.
174+
func getOptionsWithoutSecrets(values url.Values) string {
175175
var password []string
176176
if len(values["password"]) != 0 {
177177
password = values["password"]
@@ -187,7 +187,7 @@ func NewKafkaClient(uri *url.URL, topicType string) (KafkaClient, error) {
187187
if err != nil {
188188
return nil, fmt.Errorf("failed to parse url's query string: %s", err)
189189
}
190-
glog.V(3).Info(usageKafkaclient(opts))
190+
glog.V(3).Info(getOptionsWithoutSecrets(opts))
191191

192192
topic, err := getTopic(opts, topicType)
193193
if err != nil {

0 commit comments

Comments
 (0)