openwhisk-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dube...@apache.org
Subject [incubator-openwhisk] branch master updated: Remove kafka related debug message (#3223)
Date Fri, 26 Jan 2018 18:18:40 GMT
This is an automated email from the ASF dual-hosted git repository.

dubeejw pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-openwhisk.git


The following commit(s) were added to refs/heads/master by this push:
     new 97af5e6  Remove kafka related debug message (#3223)
97af5e6 is described below

commit 97af5e67f6fdca89eac74bc1afb9c22539d01f5f
Author: Martin Henke <martin.henke@web.de>
AuthorDate: Fri Jan 26 19:18:37 2018 +0100

    Remove kafka related debug message (#3223)
---
 .../src/main/scala/whisk/connector/kafka/KafkaProducerConnector.scala   | 2 --
 1 file changed, 2 deletions(-)

diff --git a/common/scala/src/main/scala/whisk/connector/kafka/KafkaProducerConnector.scala
b/common/scala/src/main/scala/whisk/connector/kafka/KafkaProducerConnector.scala
index 47dce3a..7b0977b 100644
--- a/common/scala/src/main/scala/whisk/connector/kafka/KafkaProducerConnector.scala
+++ b/common/scala/src/main/scala/whisk/connector/kafka/KafkaProducerConnector.scala
@@ -50,8 +50,6 @@ class KafkaProducerConnector(kafkahosts: String,
   override def send(topic: String, msg: Message, retry: Int = 2): Future[RecordMetadata]
= {
     implicit val transid = msg.transid
     val record = new ProducerRecord[String, String](topic, "messages", msg.serialize)
-
-    logging.debug(this, s"sending to topic '$topic' msg '$msg'")
     val produced = Promise[RecordMetadata]()
 
     producer.send(record, new Callback {

-- 
To stop receiving notification emails like this one, please contact
dubeejw@apache.org.

Mime
View raw message