add codec to DecompressionException

Author: Natalia Chuklina

topic/src/main/java/tech/ydb/topic/read/DecompressionException.java

@@ -1,5 +1,7 @@
 package tech.ydb.topic.read;
 
+import tech.ydb.topic.description.Codec;
+
 import java.io.IOException;
 import java.io.UncheckedIOException;
 
@@ -10,9 +12,11 @@ public class DecompressionException extends UncheckedIOException {
     private static final long serialVersionUID = 2720187645859527813L;
 
     private final byte[] rawData;
-    public DecompressionException(String message, IOException cause, byte[] rawData) {
+    private final Codec codec;
+    public DecompressionException(String message, IOException cause, byte[] rawData, Codec codec) {
         super(message, cause);
         this.rawData = rawData;
+        this.codec = codec;
     }
 
     /**
@@ -21,4 +25,11 @@ public DecompressionException(String message, IOException cause, byte[] rawData)
     public byte[] getRawData() {
         return rawData;
     }
+
+    /**
+     * @return Codec of message byte data
+     */
+    public Codec getCodec() {
+        return codec;
+    }
 }

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

@@ -50,7 +50,7 @@ private MessageImpl(Builder builder) {
     public byte[] getData() {
         if (exception != null) {
             throw new DecompressionException("Error occurred while decoding a message",
-                    exception, data);
+                    exception, data, batchMeta.getCodec());
         }
         return data;
     }