artin/OBP-API
1
0
Fork 0
mirror of https://github.com/OpenBankProject/OBP-API.git synced 2026-02-06 17:37:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

Trying something else for concurrency

Browse Source
This commit is contained in:
Petar Bozin 2017-04-21 18:35:32 +00:00
parent be4ffc5624
commit f155e251a3
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/scala/code/bankconnectors/KafkaHelper.scala
View File

@ -13,7 +13,12 @@ import org.apache.kafka.connect.json.JsonConverter
import scala.concurrent.ExecutionException
object KafkaHelper extends MdcLoggable {
object KafkaHelper extends KafkaHelper {
}
class KafkaHelper extends MdcLoggable {
val requestTopic = Props.get("kafka.request_topic").openOrThrowException("no kafka.request_topic set")
val responseTopic = Props.get("kafka.response_topic").openOrThrowException("no kafka.response_topic set")