Don't change Addresses in Defaults
This commit is contained in:
parent
1c430f4552
commit
43642af194
|
@ -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.Database.ConnectionString = DataSource("file:naffka.db")
|
||||
c.TopicPrefix = "Dendrite"
|
||||
|
||||
|
|
Loading…
Reference in a new issue