diff --git a/kafka/configuration.go b/kafka/configuration.go index a1b5cc8..7f219a4 100644 --- a/kafka/configuration.go +++ b/kafka/configuration.go @@ -31,7 +31,7 @@ import ( // BrokerConfiguration represents configuration of a single-instance Kafka broker type BrokerConfiguration struct { - Addresses []string `mapstructure:"address" toml:"address"` + Addresses []string `mapstructure:"addresses" toml:"addresses"` SecurityProtocol string `mapstructure:"security_protocol" toml:"security_protocol"` CertPath string `mapstructure:"cert_path" toml:"cert_path"` SaslMechanism string `mapstructure:"sasl_mechanism" toml:"sasl_mechanism"`