Need help for KafkaSteps.autoSeekTopics

[chombymat]

Hello everyone,

When my scenarios follow one another, I cannot correctly check the content of the topic in which I produce.
Unitary the tests pass.

I use the following step:
Then the topicName topic contains 0 RecordName

I think I have a configuration problem.
I have specified in the Initializer KafkaSteps.autoSeekTopics("topicName");

Can you help me?

If you need more informations please feel free to ask me.

Thanks a lot.

[alexandrepa]

Hello, can you be more precise on the exception you have. There is more than 0 messages in the topic or he can't read the topic at all ?

[alexandrepa]

I maybe have an idea of the issue, the @Aspect annotation conf are not taken in account.
Can you add this annotation :
@ComponentScan(basePackages = "com.decathlon")

On a @Configuration class in your test folder

[chombymat]

I have added the @componentscan and nothing changed.

I share my class, maybe i missed something:
@activeprofiles("test")
@RunWith(Cucumber.class)
@CucumberContextConfiguration
@componentscan(basePackages = "com.decathlon")
@CucumberOptions(
plugin = {"pretty", "json:target/cucumber.json"},
extraGlue = {"com.decathlon.tzatziki.steps"},
tags = "not @ignore")
@SpringBootTest(
classes = Application.class,
webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
@ContextConfiguration(initializers = ApplicationTest.InitializerTest.class)
public class ApplicationTest {

static final MongoDBContainer mongoDBContainer =
        new MongoDBContainer(DockerImageName.parse("mongo:4.2-bionic"));

static class InitializerTest
        implements ApplicationContextInitializer<ConfigurableApplicationContext> {

    public void initialize(ConfigurableApplicationContext configurableApplicationContext) {
        KafkaSteps.start();

        mongoDBContainer.start();
        TestPropertyValues.of(
                        "spring.data.mongodb.uri=" + mongoDBContainer.getReplicaSetUrl(),
                        "spring.kafka.consumer.auto-offset-reset=earliest",
                        "spring.kafka.bootstrap-servers=" + KafkaSteps.bootstrapServers(),
                        "spring.kafka.properties.schema.registry.url="
                                + KafkaSteps.schemaRegistryUrl())
                .applyTo(configurableApplicationContext.getEnvironment());
        KafkaSteps.autoSeekTopics("topicPublicated");
    }
}

}

[alexandrepa]

The @ComponentScan(basePackages = "com.decathlon") annotation must be set on a class that is annotated with @Configuration, can you add it on one of your conf class somewhere in your app to see if it's the problem ?

[alexandrepa]

Another way to resolve this that should work, is to add classes = KafkaInterceptor.class to the @ContextConfiguration annotation.

Should be some thing like this in your code :

@ContextConfiguration(initializers = ApplicationTest.InitializerTest.class, classes = KafkaInterceptor.class)

[chombymat]

Yes, both of your suggestions work !
That's fix the autoSeek problème AND the published on/consumed from !
Thank you very much for your help and time, I don't think I would have figured this out on my own !

[alexandrepa]

No problem, thank you to raise this issue, I'm going to update the README to be clear about that if the app is not in the com.decathlon package.