From 52cbcf3e3563e711ffa22763755b0fa8960e5a0e Mon Sep 17 00:00:00 2001 From: slavisa Date: Fri, 2 Jun 2017 10:32:48 +0200 Subject: [PATCH] another try to improve performances (without reusing connection) --- src/main/scala/code/bankconnectors/kafkaStremsHelper.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/scala/code/bankconnectors/kafkaStremsHelper.scala b/src/main/scala/code/bankconnectors/kafkaStremsHelper.scala index 2fdd274c2..7e1290111 100644 --- a/src/main/scala/code/bankconnectors/kafkaStremsHelper.scala +++ b/src/main/scala/code/bankconnectors/kafkaStremsHelper.scala @@ -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) -} \ No newline at end of file +}