From 1cb9fbd6b9fce8cbfbea620513a1d26ce7827365 Mon Sep 17 00:00:00 2001
From: Daniel Kec <daniel.kec@oracle.com>
Date: Thu, 15 Oct 2020 11:46:25 +0200
Subject: [PATCH] Log Kafka sending error which caused channel cancel (#2447)

Signed-off-by: Daniel Kec <daniel.kec@oracle.com>
---
 .../io/helidon/messaging/connectors/kafka/KafkaSubscriber.java   | 1 +
 1 file changed, 1 insertion(+)

diff --git a/messaging/kafka/src/main/java/io/helidon/messaging/connectors/kafka/KafkaSubscriber.java b/messaging/kafka/src/main/java/io/helidon/messaging/connectors/kafka/KafkaSubscriber.java
index 7e22c1635..86ed22640 100644
--- a/messaging/kafka/src/main/java/io/helidon/messaging/connectors/kafka/KafkaSubscriber.java
+++ b/messaging/kafka/src/main/java/io/helidon/messaging/connectors/kafka/KafkaSubscriber.java
@@ -96,6 +96,7 @@ public class KafkaSubscriber<K, V> implements Subscriber<Message<V>> {
             kafkaProducer.send(record, (metadata, exception) -> {
                 if (exception != null) {
                     subscription.cancel();
+                    LOGGER.log(Level.WARNING, "Error when sending kafka message to topic: " + topic, exception);
                     completableFuture.completeExceptionally(exception);
                 } else {
                     completableFuture.complete(null);