A modern programming language that makes developers happier.

kotlinlang

Hi team.

_*please: is it possible to disable Kafka during my unit tests?*_

I’ve created a class with a method using `@KafkaListener` annotation and when I run the functional tests, I produce a protobuf topic message and the listener works properly to consume that message.
But my unit test need to test this method, and I am using this:
```@Autowired
lateinit var ingestionListener: IngestionConsumerListener
```
 to inject my listener and I want to test this method but without the Kafka in memory.

But the test is trying to load the Kafka because I am getting this:
```Could not resolve placeholder 'ingestion.config.topic.name' in value "#{'${ingestion.config.topic.name}'}"
```
that is used in my implementation:
```@KafkaListener(
    id = "ingestionListener",
    topics = ["#{'\${ingestion.config.topic.name}'}"],
    groupId = "#{'\${ingestion.consumer.group.id}'}",
    concurrency = "#{'\${ingestion.config.consumer.concurrency}'}"
)
fun consumeIngestion(ingestionHttpRequest: ConsumerRecord&lt;String, IngestionHttpRequest.HttpRequest&gt;)

```
I am trying to use this kind of solution for my first unit test using Kotlin and Kafka:
```@EnableAutoConfiguration(exclude = [KafkaAutoConfiguration::class])

```
but I am still struggling with the error above…

Please any suggestion to fix that? How to test a kafka listener using Java/Kotlin without Kafka in memory?

This has nothing to do with mockk, nor Kotlin really.. Better place to ask is one of the Spring gitter channels or StackOverflow.

Also, please refrain from crossposting the same message on multiple channels. It is considered spamming.