Enabled kafkaLib connector - doesn't compile at the moment

This commit is contained in:
Petar Bozin 2016-09-21 00:12:57 +02:00
parent 8d563095a4
commit 1e54dc8442
2 changed files with 1051 additions and 1060 deletions

View File

@ -44,17 +44,8 @@ object Connector extends SimpleInjector {
case "mapped" => LocalMappedConnector
case "mongodb" => LocalConnector
case "kafka" => KafkaMappedConnector
case "kafka_lib" => KafkaLibMappedConnector
}
//
// if (connectorProps.startsWith("kafka_lib")) {
// KafkaLibMappedConnector
// } else {
// connectorProps match {
// case "mapped" => LocalMappedConnector
// case "mongodb" => LocalConnector
// case "kafka" => KafkaMappedConnector
// }
// }
}
}
@ -590,4 +581,4 @@ trait Connector {
def updateAccountLabel(bankId: BankId, accountId: AccountId, label: String): Boolean
}
}