@Nonnull
    public static <T> StreamSource<T> connect(@Nonnull Properties properties,
                                              @Nonnull FunctionEx<SourceRecord, T> projectionFn) {
        return connect(properties, projectionFn, DEFAULT_RECONNECT_BEHAVIOR);
    }
@Test
    public void should_create_source_with_minimal_properties() {
        Properties properties = new Properties();
        properties.setProperty("name", "some-name");
        properties.setProperty("connector.class", "some-name");
        StreamSource<SourceRecord> source = connect(properties, rec -> rec);
        assertThat(source).isNotNull();
    }