diff --git a/kafka-ui-api/src/main/java/com/provectus/kafka/ui/serdes/builtin/ConsumerOffsetsSerde.java b/kafka-ui-api/src/main/java/com/provectus/kafka/ui/serdes/builtin/ConsumerOffsetsSerde.java index 4b3983858a..0d006854b5 100644 --- a/kafka-ui-api/src/main/java/com/provectus/kafka/ui/serdes/builtin/ConsumerOffsetsSerde.java +++ b/kafka-ui-api/src/main/java/com/provectus/kafka/ui/serdes/builtin/ConsumerOffsetsSerde.java @@ -252,6 +252,9 @@ public class ConsumerOffsetsSerde implements BuiltInSerde { String result; var bb = ByteBuffer.wrap(data); short version = bb.getShort(); + // ideally, we should distinguish if value is commit or metadata + // by checking record's key, but our current serde structure doesn't allow that. + // so, we trying to parse into metadata first and after into commit msg try { result = toJson( switch (version) {