@Override
    public long currentStreamTimeMs() {
        throw new UnsupportedOperationException("StateStores can't access stream time.");
    }
@Test
    public void shouldThrowOnCurrentStreamTime() {
        assertThrows(UnsupportedOperationException.class, () -> context.currentStreamTimeMs());
    }