我有一个spring-boot应用程序，它使用kafka消费者和生产者。Kafka的所有配置都在application.yml上

spring:
    kafka:
        consumer:
            enable-auto-commit: true
            key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
            value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
            bootstrap-servers: kafka.dev-streams.svc.cluster.local:9092
            group-id: dev.client
        producer:
            bootstrap-servers: kafka-0.kafka-headless.dev-streams.svc.cluster.local:9092,kafka-1.kafka-headless.dev-streams.svc.cluster.local:9092,kafka-2.kafka-headless.dev-streams.svc.cluster.local:9092
            key-serializer: org.apache.kafka.common.serialization.StringSerializer
            value-serializer: org.apache.kafka.common.serialization.StringSerializer
            retries: 3

一个消费者的示例：

@KafkaListener(topics = { "${kafka.topic.internal.request}" })
        @Override
        public void processRequest(@Payload String message,
                        @Header(name = KafkaHeaders.RECEIVED_MESSAGE_KEY, required = false) String key) {
                super.processRequest(message, key);
        }

如何模拟kafka使用junit测试而不使用引导服务器来获取消费者的一些消息？