diff --git a/pom.xml b/pom.xml
index 155dca3ea..d5865a040 100644
--- a/pom.xml
+++ b/pom.xml
@@ -13,8 +13,9 @@
   <properties>
     <scala.version>2.12</scala.version>
     <scala.compiler>2.12.4</scala.compiler>
-    <akka.version>2.5.1</akka.version>
-    <akka-streams-kafka.version>0.16</akka-streams-kafka.version>
+    <akka.version>2.5.13</akka.version>
+    <akka-streams-kafka.version>0.22</akka-streams-kafka.version>
+    <kafka.version>1.1.0</kafka.version>
     <avro.version>1.8.3</avro.version>
     <lift.version>3.1.0</lift.version>
     <obp-ri.version>2016.11-RC6-SNAPSHOT</obp-ri.version>
@@ -111,12 +112,12 @@
     <dependency>
       <groupId>org.apache.kafka</groupId>
       <artifactId>kafka-clients</artifactId>
-      <version>0.11.0.0</version>
+      <version>${kafka.version}</version>
     </dependency>
     <dependency>
       <groupId>org.apache.kafka</groupId>
       <artifactId>connect-json</artifactId>
-      <version>0.11.0.0</version>
+      <version>${kafka.version}</version>
     </dependency>
     <dependency>
       <groupId>org.bouncycastle</groupId>
diff --git a/src/main/scripts/kafka/config/kafka.properties b/src/main/scripts/kafka/config/kafka.properties
index 07dcc80ff..860d84af8 100644
--- a/src/main/scripts/kafka/config/kafka.properties
+++ b/src/main/scripts/kafka/config/kafka.properties
@@ -72,7 +72,7 @@ log.dirs=tmp/kafka
 # The default number of log partitions per topic. More partitions allow greater
 # parallelism for consumption, but this will also result in more files across
 # the brokers.
-num.partitions=10
+num.partitions=3
 
 # The number of threads per data directory to be used for log recovery at startup and flushing at shutdown.
 # This value is recommended to be increased for installations with data dirs located in RAID array.