mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2025-12-26 08:13:09 -06:00
Code Issues Packages Projects Releases Wiki Activity

Removed some meaningless type conversions

Browse source
This commit is contained in:
Kilos Liu 2021-04-14 10:53:43 +08:00
parent 14561b66c8
commit 8428ff93c2
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
setup/config/config_kafka.go
View file

@ -38,7 +38,7 @@ func (c *Kafka) Defaults() {
c.UseNaffka = true
c.Database.Defaults(10)
c.Addresses = []string{"localhost:2181"}
c.Database.ConnectionString = DataSource("file:naffka.db")
c.Database.ConnectionString = "file:naffka.db"
c.TopicPrefix = "Dendrite"
maxBytes := 1024 * 1024 * 8 // about 8MB
@ -56,6 +56,6 @@ func (c *Kafka) Verify(configErrs *ConfigErrors, isMonolith bool) {
// server to talk to.
checkNotZero(configErrs, "global.kafka.addresses", int64(len(c.Addresses)))
}
checkNotEmpty(configErrs, "global.kafka.topic_prefix", string(c.TopicPrefix))
checkNotEmpty(configErrs, "global.kafka.topic_prefix", c.TopicPrefix)
checkPositive(configErrs, "global.kafka.max_message_bytes", int64(*c.MaxMessageBytes))
}