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