Embedded Kafka Problems.

[embeddedkafka]

Embedded Kafka Problems.

[SarpongAbasimi]

sure, thank you very much @francescopellegrini. I will have a look at this again tomorrow

[francescopellegrini]

Hi @SarpongAbasimi, could you please share a minimal piece of code presenting this issue?
Thank you in advance

[SarpongAbasimi]

This is the test causing the error @francescopellegrini. It passes when I run a separate schema registry container.
when I use embedded Kafka with schema Registry, I get the error mentioned above.

[SarpongAbasimi]

Hi @SarpongAbasimi, could you please share a minimal piece of code presenting this issue?
Thank you in advance

Also just to mention I am using fs2-kafka
Ref - https://fd4s.github.io/fs2-kafka/docs/consumers

[francescopellegrini]

I'm not familiar with fs2-kafka, but I think the issue here is that your testing asynchronously, while embedded-kafka stops all of its processes at the end of the withRunningKafka clojure.

You need to use something like unsafeRunSync inside the clojure to retrieve the message, only then you will be able to assert on it (which could be done after the clojure).

[SarpongAbasimi]

Thanks @francescopellegrini.

I am not sure if I understand what you mean by clojure but the assertion is being done in the withRunningKafka

[francescopellegrini]

withRunningKafka function cannot return an async computation, like IO, because it will immediately stop all containers, thus making impossibile to check the result.