@Override
    public void collect(OUT outputRecord) {
        checkOutputKey(outputRecord);
        collector.collect(outputRecord);
    }
@Test
    void testCollect() {
        TestingTimestampCollector.Builder<Integer> builder = TestingTimestampCollector.builder();
        CompletableFuture<Integer> consumeRecord = new CompletableFuture<>();
        builder.setCollectConsumer(consumeRecord::complete);
        KeyCheckedOutputCollector<Integer, Integer> collector =
                new KeyCheckedOutputCollector<>(builder.build(), (ignore) -> 1, () -> 1);

        final int record = 1;
        collector.collect(record);
        assertThat(consumeRecord).isCompletedWithValue(record);
    }