From 43642af194c4352892ab21fbb486de5c6e8bfc99 Mon Sep 17 00:00:00 2001 From: Till Faelligen Date: Sun, 30 May 2021 17:40:09 +0200 Subject: [PATCH] Don't change Addresses in Defaults --- setup/config/config_kafka.go | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) diff --git a/setup/config/config_kafka.go b/setup/config/config_kafka.go index dce81e34..64b4ad32 100644 --- a/setup/config/config_kafka.go +++ b/setup/config/config_kafka.go @@ -49,12 +49,7 @@ func (k *Kafka) TopicFor(name string) string { func (c *Kafka) Defaults() { c.UseNaffka = true c.Database.Defaults() - if c.UseNATS { - c.UseNaffka = false - c.Addresses = []string{"nats://127.0.0.1:4222"} - } else { - c.Addresses = []string{"localhost:2181"} - } + c.Addresses = []string{"localhost:2181"} c.Database.ConnectionString = DataSource("file:naffka.db") c.TopicPrefix = "Dendrite"