Skip to content

Commit

Permalink
Set ConfigEntry.Default for KafkaVersions > 0
Browse files Browse the repository at this point in the history
Clients can now rely on the `Default` flag again and don't have to check the `Source` for higher Kafka versions.
  • Loading branch information
sladkoff committed Jan 31, 2020
1 parent 7fd0ce5 commit 67d222f
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions describe_configs_response.go
Original file line number Diff line number Diff line change
Expand Up @@ -255,6 +255,7 @@ func (r *ConfigEntry) decode(pd packetDecoder, version int16) (err error) {
return err
}
r.Source = ConfigSource(source)
r.Default = r.Source == SourceDefault
}

sensitive, err := pd.getBool()
Expand Down

0 comments on commit 67d222f

Please sign in to comment.