Тестирование Kafka Mockito в Spring Boot

Я заметил проблему, заключающуюся в том, что я не могу должным образом протестировать метод listen(), помеченный аннотацией @KafkaListener, потому что даже если я создам фиктивный объект моего Kafka Consumer, при отправке сообщения с помощью kafkaTemplate.send() это не будет фиктивный объект, который будет вызван.

Я попытался фиктивно создать своего Kafka Consumer, чтобы перехватить метод listen(), помеченный аннотацией @KafkaListener, но это не фиктивный объект, который вызывается при отправке сообщения, поэтому я не могу переопределить поведение метода listen().