Fix typo in mongo sink settings: kqcl -> kcql.

Signed-off-by: Marios Andreopoulos <[email protected]>
lensesio · Nov 13, 2016 · d711c68 · d711c68
1 parent e28cfdc
commit d711c68
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...src/main/scala/com/datamountaineer/streamreactor/connect/mongodb/config/MongoConfig.scala b/...src/main/scala/com/datamountaineer/streamreactor/connect/mongodb/config/MongoConfig.scala
@@ -49,7 +49,7 @@ object MongoConfig {
   val NBR_OF_RETRIES_DOC = "The maximum number of times to try the write again."
   val NBR_OF_RETIRES_DEFAULT = 20
 
-  val KCQL_CONFIG = "connect.mongo.sink.kqcl"
+  val KCQL_CONFIG = "connect.mongo.sink.kcql"
   val KCQL_DOC = "KCQL expression describing field selection and data routing to the target mongo db."
 
 

diff --git a/...cala/com/datamountaineer/streamreactor/connect/mongodb/config/MongoSinkSettingsTest.scala b/...cala/com/datamountaineer/streamreactor/connect/mongodb/config/MongoSinkSettingsTest.scala
@@ -83,7 +83,7 @@ class MongoSinkSettingsTest extends WordSpec with Matchers {
       settings.ignoredField shouldBe Map("topic1" -> Set.empty)
     }
 
-    "throw an exception if the kqcl is not valid" in {
+    "throw an exception if the kcql is not valid" in {
       val map = Map(
         MongoConfig.DATABASE_CONFIG -> "database1",
         MongoConfig.CONNECTION_CONFIG -> "mongodb://localhost:27017",