diff --git a/setup/config/config_kafka.go b/setup/config/config_kafka.go index d21e6c57..dce81e34 100644 --- a/setup/config/config_kafka.go +++ b/setup/config/config_kafka.go @@ -51,9 +51,9 @@ func (c *Kafka) Defaults() { c.Database.Defaults() if c.UseNATS { c.UseNaffka = false - c.Addresses = []string{"localhost:2181"} - } else { c.Addresses = []string{"nats://127.0.0.1:4222"} + } else { + c.Addresses = []string{"localhost:2181"} } c.Database.ConnectionString = DataSource("file:naffka.db") c.TopicPrefix = "Dendrite"