@Test(expected = DataException.class)
public void nullToConnect() {

    // When schemas are enabled, trying to decode a null should be an error -- we should *always* have the envelope
    assertEquals(SchemaAndValue.NULL, converter.toConnectData(TOPIC, null));
}