public void setSourceConnectorWrapper(SourceConnectorWrapper sourceConnectorWrapper) {
        this.sourceConnectorWrapper = sourceConnectorWrapper;
    }
@Test
    void should_require_projectionFn() {
        var wrapper = new SourceConnectorWrapper(minimalProperties(), 0, context);
        assertThatThrownBy(() -> new ReadKafkaConnectP<>(noEventTime(), null)
                .setSourceConnectorWrapper(wrapper))
                .isInstanceOf(NullPointerException.class)
                .hasMessage("projectionFn is required");
    }