static String tryToExtractErrorMessage(Reconciliation reconciliation, Buffer buffer)    {
        try {
            return buffer.toJsonObject().getString("message");
        } catch (DecodeException e) {
            LOGGER.warnCr(reconciliation, "Failed to decode the error message from the response: " + buffer, e);
        }

        return "Unknown error message";
    }
@Test
    public void testJsonDecoding()  {
        assertThat(KafkaConnectApiImpl.tryToExtractErrorMessage(Reconciliation.DUMMY_RECONCILIATION, Buffer.buffer("{\"message\": \"This is the error\"}")), is("This is the error"));
        assertThat(KafkaConnectApiImpl.tryToExtractErrorMessage(Reconciliation.DUMMY_RECONCILIATION, Buffer.buffer("{\"message\": \"This is the error\"")), is("Unknown error message"));
        assertThat(KafkaConnectApiImpl.tryToExtractErrorMessage(Reconciliation.DUMMY_RECONCILIATION, Buffer.buffer("Not a JSON")), is("Unknown error message"));
    }