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