This is an automated email from the ASF dual-hosted git repository.
rabbah 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 2467c6b log exception when ensureTopic fails with unexpected
exception (#3017)
2467c6b is described below
commit 2467c6bc10658f5c4f8520e474a4418beb284d32
Author: David Grove <dgrove-...@users.noreply.github.com>
AuthorDate: Tue Dec 5 14:28:16 2017 -0500
log exception when ensureTopic fails with unexpected exception (#3017)
---
.../src/main/scala/whisk/connector/kafka/KafkaMessagingProvider.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/common/scala/src/main/scala/whisk/connector/kafka/KafkaMessagingProvider.scala
b/common/scala/src/main/scala/whisk/connector/kafka/KafkaMessagingProvider.scala
index 5c61cc6..599b5bf 100644
---
a/common/scala/src/main/scala/whisk/connector/kafka/KafkaMessagingProvider.scala
+++
b/common/scala/src/main/scala/whisk/connector/kafka/KafkaMessagingProvider.scala
@@ -64,8 +64,8 @@ object KafkaMessagingProvider extends MessagingProvider {
case e: ExecutionException if
e.getCause.isInstanceOf[TopicExistsException] =>
logging.info(this, s"topic $topic already existed")
true
- case _: Exception =>
- logging.error(this, s"exception during creation of topic $topic")
+ case e: Exception =>
+ logging.error(this, s"ensureTopic for $topic failed due to $e")
false
} finally {
client.close()
--
To stop receiving notification emails like this one, please contact
['"commits@openwhisk.apache.org" <commits@openwhisk.apache.org>'].
