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

    Map<Integer, Object> data = new HashMap<>();
    data.put(1, "abc");
    data.put(2, "wrong".getBytes());
    ConnectSchema.validateValue(MAP_INT_STRING_SCHEMA, data);
}