public synchronized void add(byte[] element) throws IOException {
        if (currentBatch.size() >= BATCHSIZE) {
            flush();
        }
        currentBatch.add(element);
        writeIntoCompressedStream(element);
    }
@Test
    @Disabled
    void benchmark() throws IOException {
        final int count = BATCHSIZE * 100000;
        for (int i = 1; i <= count; i++) {
            buffer.add(("Loop " + i + "\n").getBytes(StandardCharsets.UTF_8));
        }
    }