Print to log if decoding job failed

Author: pnv1

topic/src/main/java/tech/ydb/topic/read/impl/PartitionSessionImpl.java

@@ -166,7 +166,11 @@ public CompletableFuture<Void> addBatches(List<YdbTopic.StreamReadMessage.ReadRe
             }
 
             CompletableFuture.runAsync(() -> decode(newBatch), decompressionExecutor)
-                    .thenRun(() -> {
+                    .whenComplete((res, th) -> {
+                        if (th != null) {
+                            logger.error("[{}] Message decoding failed with error: ", fullId, th);
+                            return;
+                        }
                         boolean haveNewBatchesReady = false;
                         decodingBatchesLock.lock();