@Nonnull
    public static <T> StreamSource<T> connect(@Nonnull Properties properties,
                                              @Nonnull FunctionEx<SourceRecord, T> projectionFn) {
        return connect(properties, projectionFn, DEFAULT_RECONNECT_BEHAVIOR);
    }
@SuppressWarnings("ConstantConditions")
    @Test
    public void should_fail_when_no_projectionFn() {
        Properties properties = new Properties();
        properties.setProperty("name", "some-name");
        properties.setProperty("connector.class", "some-name");
        assertThatThrownBy(() -> connect(properties, null))
                .isInstanceOf(NullPointerException.class)
                .hasMessage("projectionFn is required");
    }