Skip to content

Commit

Permalink
Feat: rename kafka source config SASL to sasl (#464)
Browse files Browse the repository at this point in the history
  • Loading branch information
ethfoo committed Feb 7, 2023
1 parent 3fefda3 commit d019b06
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion pkg/source/kafka/config.go
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,7 @@ type Config struct {
EnableAutoCommit bool `yaml:"enableAutoCommit"`
AutoCommitInterval time.Duration `yaml:"autoCommitInterval" default:"1s"`
AutoOffsetReset string `yaml:"autoOffsetReset" default:"latest" validate:"oneof=earliest latest"`
SASL kakfasink.SASL `yaml:"SASL,omitempty"`
SASL kakfasink.SASL `yaml:"sasl,omitempty"`
}

func getAutoOffset(autoOffsetReset string) int64 {
Expand Down

0 comments on commit d019b06

Please sign in to comment.