@Override
    public TopicConsumerBuilder<T> priorityLevel(int priorityLevel) {
        checkArgument(priorityLevel >= 0, "priorityLevel needs to be >= 0");
        topicConf.setPriorityLevel(priorityLevel);
        return this;
    }
@Test
    public void testInvalidPriorityLevel() {
        assertThatIllegalArgumentException()
                .isThrownBy(() -> topicConsumerBuilderImpl.priorityLevel(-1));
        verify(topicConsumerConfigurationData, never()).setPriorityLevel(anyInt());
    }