From 3f17b28d3b06bb4a6fbd2faf12108f9a61042800 Mon Sep 17 00:00:00 2001
From: Andrew Stevenson <andrew@datamountaineer.com>
Date: Wed, 31 Aug 2016 12:31:44 +0200
Subject: [PATCH] remove printing of settings

---
 .../streamreactor/connect/influx/InfluxSinkTask.scala         | 2 --
 .../streamreactor/connect/jms/JMSSinkTask.scala               | 4 ----
 .../streamreactor/connect/redis/sink/RedisSinkTask.scala      | 4 ----
 .../connect/redis/sink/writer/RedisDbWriter.scala             | 2 +-
 .../streamreactor/connect/voltdb/VoltSinkTask.scala           | 2 --
 5 files changed, 1 insertion(+), 13 deletions(-)

diff --git a/kafka-connect-influxdb/src/main/scala/com/datamountaineer/streamreactor/connect/influx/InfluxSinkTask.scala b/kafka-connect-influxdb/src/main/scala/com/datamountaineer/streamreactor/connect/influx/InfluxSinkTask.scala
index 96e249e0d..80a11c84e 100755
--- a/kafka-connect-influxdb/src/main/scala/com/datamountaineer/streamreactor/connect/influx/InfluxSinkTask.scala
+++ b/kafka-connect-influxdb/src/main/scala/com/datamountaineer/streamreactor/connect/influx/InfluxSinkTask.scala
@@ -61,13 +61,11 @@ class InfluxSinkTask extends SinkTask with StrictLogging {
     val sinkConfig = InfluxSinkConfig(props)
     val influxSettings = InfluxSettings(sinkConfig)
 
-
     //if error policy is retry set retry interval
     if (influxSettings.errorPolicy.equals(ErrorPolicyEnum.RETRY)) {
       context.timeout(sinkConfig.getInt(InfluxSinkConfig.ERROR_RETRY_INTERVAL_CONFIG).toLong)
     }
 
-    logger.info(s"Settings:$influxSettings")
     writer = Some(WriterFactoryFn(influxSettings))
   }
 
diff --git a/kafka-connect-jms/src/main/scala/com/datamountaineer/streamreactor/connect/jms/JMSSinkTask.scala b/kafka-connect-jms/src/main/scala/com/datamountaineer/streamreactor/connect/jms/JMSSinkTask.scala
index befbbe2ac..a3e176a81 100755
--- a/kafka-connect-jms/src/main/scala/com/datamountaineer/streamreactor/connect/jms/JMSSinkTask.scala
+++ b/kafka-connect-jms/src/main/scala/com/datamountaineer/streamreactor/connect/jms/JMSSinkTask.scala
@@ -67,10 +67,6 @@ class JMSSinkTask extends SinkTask with StrictLogging {
       context.timeout(sinkConfig.getInt(JMSSinkConfig.ERROR_RETRY_INTERVAL).toLong)
     }
 
-    logger.info(
-      s"""Settings:
-          |$settings
-      """.stripMargin)
     writer = Some(JMSWriter(settings))
   }
 
diff --git a/kafka-connect-redis/src/main/scala/com/datamountaineer/streamreactor/connect/redis/sink/RedisSinkTask.scala b/kafka-connect-redis/src/main/scala/com/datamountaineer/streamreactor/connect/redis/sink/RedisSinkTask.scala
index 73b13da8c..af7549de6 100755
--- a/kafka-connect-redis/src/main/scala/com/datamountaineer/streamreactor/connect/redis/sink/RedisSinkTask.scala
+++ b/kafka-connect-redis/src/main/scala/com/datamountaineer/streamreactor/connect/redis/sink/RedisSinkTask.scala
@@ -70,10 +70,6 @@ class RedisSinkTask extends SinkTask with StrictLogging {
       context.timeout(sinkConfig.getInt(RedisSinkConfig.ERROR_RETRY_INTERVAL).toLong)
     }
 
-    logger.info(
-      s"""Settings:
-          |$settings
-      """.stripMargin)
     writer = Some(RedisDbWriterFactory(settings))
   }
 
diff --git a/kafka-connect-redis/src/main/scala/com/datamountaineer/streamreactor/connect/redis/sink/writer/RedisDbWriter.scala b/kafka-connect-redis/src/main/scala/com/datamountaineer/streamreactor/connect/redis/sink/writer/RedisDbWriter.scala
index 4bace22e5..dab32a94b 100755
--- a/kafka-connect-redis/src/main/scala/com/datamountaineer/streamreactor/connect/redis/sink/writer/RedisDbWriter.scala
+++ b/kafka-connect-redis/src/main/scala/com/datamountaineer/streamreactor/connect/redis/sink/writer/RedisDbWriter.scala
@@ -32,7 +32,7 @@ import scala.util.Try
 case class RedisDbWriter(sinkSettings: RedisSinkSettings) extends DbWriter with StrictLogging with ConverterUtil with ErrorHandler {
   private val connection = sinkSettings.connection
   private val jedis = new Jedis(connection.host, connection.port)
-  connection.password.foreach(jedis.auth)
+  connection.password.foreach(p => jedis.auth(p))
 
   //initialize error tracker
   initialize(sinkSettings.taskRetries, sinkSettings.errorPolicy)
diff --git a/kafka-connect-voltdb/src/main/scala/com/datamountaineer/streamreactor/connect/voltdb/VoltSinkTask.scala b/kafka-connect-voltdb/src/main/scala/com/datamountaineer/streamreactor/connect/voltdb/VoltSinkTask.scala
index f639ab37b..38659cf9d 100755
--- a/kafka-connect-voltdb/src/main/scala/com/datamountaineer/streamreactor/connect/voltdb/VoltSinkTask.scala
+++ b/kafka-connect-voltdb/src/main/scala/com/datamountaineer/streamreactor/connect/voltdb/VoltSinkTask.scala
@@ -67,8 +67,6 @@ class VoltSinkTask extends SinkTask with StrictLogging {
     if (voltSettings.errorPolicy.equals(ErrorPolicyEnum.RETRY)) {
       context.timeout(sinkConfig.getInt(VoltSinkConfig.ERROR_RETRY_INTERVAL_CONFIG).toLong)
     }
-
-    logger.info(s"Settings:$VoltSettings")
     writer = Some(new VoltDbWriter(voltSettings))
   }