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

another try to improve performances (without reusing connection)

Browse Source
This commit is contained in:
slavisa 2017-06-02 10:32:48 +02:00
parent 03e784f895
commit 52cbcf3e35
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/scala/code/bankconnectors/kafkaStremsHelper.scala
View File

@ -45,7 +45,7 @@ class KafkaStreamsHelperActor extends Actor with ObpActorInit with ObpActorHelpe
private val consumer: Source[ConsumerRecord[String, String], Consumer.Control] = {
val assignment = Subscriptions.assignmentWithOffset(new TopicPartition(Topics.connectorTopic.response, 0), 0)
Consumer.plainExternalSource(consumerActor, assignment)
Consumer.plainSource(consumerSettings, assignment)
.completionTimeout(completionTimeout)
}
@ -130,4 +130,4 @@ object Topics {
val connectorTopic = Topic(requestTopic, responseTopic)
}
}