Merge pull request #55 from ing-bank/bug/kafka-sessions

Fix number of sessions to kafka
ing-bank · Mar 13, 2019 · 9651764 · 9651764
2 parents 5284a79 + 9be330c
commit 9651764
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/build.sbt b/build.sbt
@@ -3,7 +3,7 @@ import com.typesafe.sbt.packager.docker.ExecCmd
 import scalariform.formatter.preferences._
 
 name := "airlock"
-version := "0.1.13"
+version := "0.1.16"
 
 scalaVersion := "2.12.8"
 

diff --git a/src/it/scala/com/ing/wbaa/airlock/proxy/provider/MessageProviderKafkaItTest.scala b/src/it/scala/com/ing/wbaa/airlock/proxy/provider/MessageProviderKafkaItTest.scala
@@ -33,7 +33,7 @@ class MessageProviderKafkaItTest extends WordSpecLike with DiagrammedAssertions
       withRunningKafka {
         val createEventsTopic = "create_events"
         createCustomTopic(createEventsTopic)
-
+        Thread.sleep(3000)
         emitEvent(s3Request, HttpMethods.PUT, "testUser")
         val result = consumeFirstStringMessageFrom(createEventsTopic)
         assert(result.contains("s3:ObjectCreated:PUT"))
@@ -46,7 +46,7 @@ class MessageProviderKafkaItTest extends WordSpecLike with DiagrammedAssertions
       withRunningKafka {
         val deleteEventsTopic = "delete_events"
         createCustomTopic(deleteEventsTopic)
-
+        Thread.sleep(3000)
         emitEvent(s3Request, HttpMethods.DELETE, "testUser")
         assert(consumeFirstStringMessageFrom(deleteEventsTopic).contains("s3:ObjectRemoved:DELETE"))
       }

diff --git a/src/main/scala/com/ing/wbaa/airlock/proxy/provider/kafka/EventProducer.scala b/src/main/scala/com/ing/wbaa/airlock/proxy/provider/kafka/EventProducer.scala
@@ -30,7 +30,7 @@ trait EventProducer extends LazyLogging {
       ProducerConfig.MAX_BLOCK_MS_CONFIG -> kafkaSettings.maxblock
     )
 
-  def kafkaProducer: KafkaProducer[String, String] = new KafkaProducer(config.asJava, new StringSerializer, new StringSerializer)
+  private lazy val kafkaProducer: KafkaProducer[String, String] = new KafkaProducer(config.asJava, new StringSerializer, new StringSerializer)
 
   def sendSingleMessage(event: String, topic: String): Future[Done] = {
     kafkaProducer