Set ConfigEntry.Source to default for KafkaVersions <= 0 when applicable

IBM · Jan 31, 2020 · 51ba5d7 · 51ba5d7
1 parent 67d222f
commit 51ba5d7
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/describe_configs_response.go b/describe_configs_response.go
@@ -249,6 +249,9 @@ func (r *ConfigEntry) decode(pd packetDecoder, version int16) (err error) {
 			return err
 		}
 		r.Default = defaultB
+		if defaultB {
+			r.Source = SourceDefault
+		}
 	} else {
 		source, err := pd.getInt8()
 		if err != nil {