Skip to content

Commit 1b5e305

Browse files
committed
Set ConfigEntry.Source to default for KafkaVersions <= 0 when applicable
1 parent 26c3bc5 commit 1b5e305

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

describe_configs_response.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -249,6 +249,9 @@ func (r *ConfigEntry) decode(pd packetDecoder, version int16) (err error) {
249249
return err
250250
}
251251
r.Default = defaultB
252+
if defaultB {
253+
r.Source = SourceDefault
254+
}
252255
} else {
253256
source, err := pd.getInt8()
254257
if err != nil {

0 commit comments

Comments
 (0)