From 9c80c69cecf0b18f01531fa0a91ebf54c3f12ac1 Mon Sep 17 00:00:00 2001 From: Mati Urban Date: Wed, 25 Sep 2024 14:01:03 +0200 Subject: [PATCH] Added error logging (the one we get from GCS library) --- .../gcp/storage/storage/GCPStorageStorageInterface.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kafka-connect-gcp-storage/src/main/scala/io/lenses/streamreactor/connect/gcp/storage/storage/GCPStorageStorageInterface.scala b/kafka-connect-gcp-storage/src/main/scala/io/lenses/streamreactor/connect/gcp/storage/storage/GCPStorageStorageInterface.scala index 31f7c1bb2..707773d7c 100644 --- a/kafka-connect-gcp-storage/src/main/scala/io/lenses/streamreactor/connect/gcp/storage/storage/GCPStorageStorageInterface.scala +++ b/kafka-connect-gcp-storage/src/main/scala/io/lenses/streamreactor/connect/gcp/storage/storage/GCPStorageStorageInterface.scala @@ -75,7 +75,7 @@ class GCPStorageStorageInterface( } logger.info(s"[{}] Completed upload from local {} to Storage {}:{}", connectorTaskId.show, source, bucket, path) }.toEither.leftMap { ex: Throwable => - logger.error(s"[{}] Failed upload from local {} to Storage {}:{}", + logger.error(s"[{}] Failed upload from local {} to Storage {}:{}. Reason:{}", connectorTaskId.show, source, bucket,