Logs

Haarolean · Haarolean · commit fc59e6b7f541 · 2025-09-26T12:44:29.000+03:00
diff --git a/api/src/main/java/io/kafbat/ui/serdes/builtin/mm2/CheckpointSerde.java b/api/src/main/java/io/kafbat/ui/serdes/builtin/mm2/CheckpointSerde.java
@@ -92,8 +92,8 @@ public Deserializer deserializer(String topic, Target target) {
               var result = OBJECT_MAPPER.writeValueAsString(map);
               yield new DeserializeResult(result, DeserializeResult.Type.JSON, Map.of());
             } catch (JsonProcessingException e) {
-              log.error("Error serializing record", e);
-              throw new RuntimeException(e);
+              log.error("Error deserializing record", e);
+              throw new RuntimeException("Error deserializing record", e);
             }
           }
 
@@ -118,8 +118,8 @@ public Deserializer deserializer(String topic, Target target) {
               var result = OBJECT_MAPPER.writeValueAsString(map);
               yield new DeserializeResult(result, DeserializeResult.Type.JSON, Map.of());
             } catch (JsonProcessingException e) {
-              log.error("Error serializing record", e);
-              throw new RuntimeException(e);
+              log.error("Error deserializing record", e);
+              throw new RuntimeException("Error deserializing record", e);
             }
           }
 
diff --git a/api/src/main/java/io/kafbat/ui/serdes/builtin/mm2/HeartbeatSerde.java b/api/src/main/java/io/kafbat/ui/serdes/builtin/mm2/HeartbeatSerde.java
@@ -83,8 +83,8 @@ public Deserializer deserializer(String topic, Target target) {
               var result = OBJECT_MAPPER.writeValueAsString(map);
               yield new DeserializeResult(result, DeserializeResult.Type.JSON, Map.of());
             } catch (JsonProcessingException e) {
-              log.error("Error serializing record", e);
-              throw new RuntimeException(e);
+              log.error("Error deserializing record", e);
+              throw new RuntimeException("Error deserializing record", e);
             }
           }
 
diff --git a/api/src/main/java/io/kafbat/ui/serdes/builtin/mm2/OffsetSyncSerde.java b/api/src/main/java/io/kafbat/ui/serdes/builtin/mm2/OffsetSyncSerde.java
@@ -79,8 +79,8 @@ public Deserializer deserializer(String topic, Target target) {
               var result = OBJECT_MAPPER.writeValueAsString(map);
               yield new DeserializeResult(result, DeserializeResult.Type.JSON, Map.of());
             } catch (JsonProcessingException e) {
-              log.error("Error serializing record", e);
-              throw new RuntimeException(e);
+              log.error("Error deserializing record", e);
+              throw new RuntimeException("Error deserializing record", e);
             }
           }
 
@@ -95,8 +95,8 @@ public Deserializer deserializer(String topic, Target target) {
               var result = OBJECT_MAPPER.writeValueAsString(map);
               yield new DeserializeResult(result, DeserializeResult.Type.JSON, Map.of());
             } catch (JsonProcessingException e) {
-              log.error("Error serializing record", e);
-              throw new RuntimeException(e);
+              log.error("Error deserializing record", e);
+              throw new RuntimeException("Error deserializing record", e);
             }
           }
 

Original file line number	Diff line number	Diff line change
`@@ -92,8 +92,8 @@ public Deserializer deserializer(String topic, Target target) {`
`92`	`92`	`var result = OBJECT_MAPPER.writeValueAsString(map);`
`93`	`93`	`yield new DeserializeResult(result, DeserializeResult.Type.JSON, Map.of());`
`94`	`94`	`} catch (JsonProcessingException e) {`
`95`		`- log.error("Error serializing record", e);`
`96`		`- throw new RuntimeException(e);`
	`95`	`+ log.error("Error deserializing record", e);`
	`96`	`+ throw new RuntimeException("Error deserializing record", e);`
`97`	`97`	`}`
`98`	`98`	`}`
`99`	`99`
`@@ -118,8 +118,8 @@ public Deserializer deserializer(String topic, Target target) {`
`118`	`118`	`var result = OBJECT_MAPPER.writeValueAsString(map);`
`119`	`119`	`yield new DeserializeResult(result, DeserializeResult.Type.JSON, Map.of());`
`120`	`120`	`} catch (JsonProcessingException e) {`
`121`		`- log.error("Error serializing record", e);`
`122`		`- throw new RuntimeException(e);`
	`121`	`+ log.error("Error deserializing record", e);`
	`122`	`+ throw new RuntimeException("Error deserializing record", e);`
`123`	`123`	`}`
`124`	`124`	`}`
`125`	`125`
Original file line number	Diff line number	Diff line change
`@@ -83,8 +83,8 @@ public Deserializer deserializer(String topic, Target target) {`
`83`	`83`	`var result = OBJECT_MAPPER.writeValueAsString(map);`
`84`	`84`	`yield new DeserializeResult(result, DeserializeResult.Type.JSON, Map.of());`
`85`	`85`	`} catch (JsonProcessingException e) {`
`86`		`- log.error("Error serializing record", e);`
`87`		`- throw new RuntimeException(e);`
	`86`	`+ log.error("Error deserializing record", e);`
	`87`	`+ throw new RuntimeException("Error deserializing record", e);`
`88`	`88`	`}`
`89`	`89`	`}`
`90`	`90`
Original file line number	Diff line number	Diff line change
`@@ -79,8 +79,8 @@ public Deserializer deserializer(String topic, Target target) {`
`79`	`79`	`var result = OBJECT_MAPPER.writeValueAsString(map);`
`80`	`80`	`yield new DeserializeResult(result, DeserializeResult.Type.JSON, Map.of());`
`81`	`81`	`} catch (JsonProcessingException e) {`
`82`		`- log.error("Error serializing record", e);`
`83`		`- throw new RuntimeException(e);`
	`82`	`+ log.error("Error deserializing record", e);`
	`83`	`+ throw new RuntimeException("Error deserializing record", e);`
`84`	`84`	`}`
`85`	`85`	`}`
`86`	`86`
`@@ -95,8 +95,8 @@ public Deserializer deserializer(String topic, Target target) {`
`95`	`95`	`var result = OBJECT_MAPPER.writeValueAsString(map);`
`96`	`96`	`yield new DeserializeResult(result, DeserializeResult.Type.JSON, Map.of());`
`97`	`97`	`} catch (JsonProcessingException e) {`
`98`		`- log.error("Error serializing record", e);`
`99`		`- throw new RuntimeException(e);`
	`98`	`+ log.error("Error deserializing record", e);`
	`99`	`+ throw new RuntimeException("Error deserializing record", e);`
`100`	`100`	`}`
`101`	`101`	`}`
`102`	`102`