boolean eosEnabled() {
        return StreamsConfigUtils.eosEnabled(processingMode);
    }
@Test
    public void shouldEnableEosIfEosBetaEnabled() {
        assertThat(eosBetaStreamsProducer.eosEnabled(), is(true));
    }