undo undo commit issue #139 - new KafkaLibMapeedConnector

pom.xml

@@ -209,11 +209,6 @@
       <artifactId>signpost-commonshttp4</artifactId>
       <version>1.2.1.2</version>
     </dependency>
-    <dependency>
-      <groupId>com.tesobe.obp</groupId>
-      <artifactId>obp-ri-kafka</artifactId>
-      <version>2016.0-SNAPSHOT</version>
-    </dependency>
   </dependencies>
 
   <build>

src/main/scala/code/bankconnectors/Connector.scala

@@ -40,15 +40,21 @@ object Connector  extends SimpleInjector {
   def buildOne: Connector = {
     val connectorProps = Props.get("connector").openOrThrowException("no connector set")
 
-    if (connectorProps.startsWith("kafka_lib")) {
-      KafkaLibMappedConnector
-    } else {
-      connectorProps match {
-        case "mapped" => LocalMappedConnector
-        case "mongodb" => LocalConnector
-        case "kafka" => KafkaMappedConnector
-      }
+    connectorProps match {
+      case "mapped" => LocalMappedConnector
+      case "mongodb" => LocalConnector
+      case "kafka" => KafkaMappedConnector
     }
+//
+//    if (connectorProps.startsWith("kafka_lib")) {
+//      KafkaLibMappedConnector
+//    } else {
+//      connectorProps match {
+//        case "mapped" => LocalMappedConnector
+//        case "mongodb" => LocalConnector
+//        case "kafka" => KafkaMappedConnector
+//      }
+//    }
   }
 
 }