Как проверить работоспособную задачу с помощью TestNG?

Question

Я создаю сервис с использованием java и хочу протестировать его с помощью TestNG. Я новичок в TestNG. Ниже приведен снимок службы, которую я написал:

А вот тестовый файл, который я написал:

test. java

String topicList = "test"; // UTA: default value
Properties kafkaConsumerProperties = new Properties(); // UTA: default value

kafkaConsumerProperties.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
kafkaConsumerProperties.put(ConsumerConfig.GROUP_ID_CONFIG, "GRPID");
kafkaConsumerProperties.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, LongDeserializer.class.getName());
kafkaConsumerProperties.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());

// When
int poolCoreSize = 10; // UTA: default value
int poolMaxSize = 10; // UTA: default value
long poolKeepAliveMs = 10L; // UTA: default value
int msAckerInterval = 10; // UTA: default value
Processor processor = mock(Processor.class);

long submitRetryIntervalMs = 0L;

ThreadPoolConfig threadPoolConfig=mock(ThreadPoolConfig.class);

ConsumerService consumerService=mock(ConsumerService.class);
ConsumerAttributes attr = new ConsumerAttributes(topicList, kafkaConsumerProperties, poolCoreSize, poolMaxSize, poolKeepAliveMs, msAckerInterval);
Consumer consumer = new Consumer(attr, "null", kafkaConsumerProperties);
consumer.runConsumerService(processor, Mockito.anyLong());

Но, как видите, задача runnable2 пропускается при тестировании службы. Как мне проверить задачу runnable2? Нужно ли создавать новую тему для проверки этой конкретной строки? Я попытался найти inte rnet, но не смог найти решение. Заранее спасибо.