public ConsumerBuilder threads(Integer threads) {
        this.threads = threads;
        return getThis();
    }
@Test
    void threads() {
        ConsumerBuilder builder = ConsumerBuilder.newBuilder();
        builder.threads(100);
        Assertions.assertEquals(100, builder.build().getThreads());
    }