### Question:
JsonToTransactionTransformer { public JSONObject transform(JSONObject jsonObject) { JSONObject after = jsonObject.getJSONObject("payload").getJSONObject("after"); String amount = after.getString("amount"); byte[] decode = Base64.getDecoder().decode(amount); after.put("amount", new BigDecimal(new BigInteger(decode), 2).toString()); return after; }  JSONObject transform(JSONObject jsonObject);  }### Answer:
@Test public void process() throws IOException { InputStream inputStream = getClass().getResourceAsStream("/debezium-message.json"); String message = new String(ByteStreams.toByteArray(inputStream), Charsets.UTF_8); JsonToTransactionTransformer transformer = new JsonToTransactionTransformer(); JSONObject transformed = transformer.transform(new JSONObject(message)); assertEquals(transformed.getString("operation"), "C"); assertEquals(transformed.getBigDecimal("amount"), new BigDecimal("1000.00")); System.out.println(transformed); }