fix: パラメーターを忘れてたのを修正

This commit is contained in:
usbharu 2024-04-15 14:52:01 +09:00
parent 786740e294
commit 86d0366ab5
1 changed files with 2 additions and 1 deletions

View File

@ -30,7 +30,8 @@ object StandaloneConsumerConfigLoader {
val port = properties.getProperty("port").toInt()
val name = properties.getProperty("name")
val hostname = properties.getProperty("hostname")
val concurrency = properties.getProperty("concurrency").toInt()
return StandaloneConsumerConfig(address, port, name, hostname)
return StandaloneConsumerConfig(address, port, name, hostname, concurrency)
}
}