if (connectorConfig.plugin().isYBOutput()) {
    if (value != null && !UnchangedToastedReplicationMessageColumn.isUnchangedToastedValue(value)) {
        value = converter.convert(((Object[]) value)[0]);
        Struct cell = new Struct(fields[i].schema());
        cell.put("value", value);
        cell.put("set", true);
        result.put(fields[i], cell);
    } else {
        result.put(fields[i], null);
    }
} else {
    result.put(fields[i], value);
}

...
else {
  value = converter.convert(value);
  result.put(fields[i], value);
}
...