From 51ba5d76aae520e2ae60c336faaaa4169084aad1 Mon Sep 17 00:00:00 2001
From: Leonid Koftun <leonid.koftun@device-insight.com>
Date: Fri, 31 Jan 2020 15:53:16 +0100
Subject: [PATCH] Set ConfigEntry.Source to default for KafkaVersions <= 0 when
 applicable

---
 describe_configs_response.go | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/describe_configs_response.go b/describe_configs_response.go
index 7b7994094c..dd919f1279 100644
--- 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 {