@Test
public void shouldThrowWhenConvertRawByteArrayFromConnectData() {

    try {
        converter.fromConnectData(TOPIC, Schema.BOOLEAN_SCHEMA, null);
        fail("now expected exception thrown");
    }
    catch (Exception e) {
        assertThat(e).isExactlyInstanceOf(DataException.class);
    }
}