Comments (7)
sure, thank you very much @francescopellegrini. I will have a look at this again tomorrow
from embedded-kafka-schema-registry.
Hi @SarpongAbasimi, could you please share a minimal piece of code presenting this issue?
Thank you in advance
from embedded-kafka-schema-registry.
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.
from embedded-kafka-schema-registry.
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
from embedded-kafka-schema-registry.
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).
from embedded-kafka-schema-registry.
Thanks @francescopellegrini.
I am not sure if I understand what you mean by clojure
but the assertion is being done in the withRunningKafka
from embedded-kafka-schema-registry.
withRunningKafka
function cannot return an async computation, like IO
, because it will immediately stop all containers, thus making impossibile to check the result.
from embedded-kafka-schema-registry.
Related Issues (20)
- Move Kafka Streams to its own project HOT 2
- Expose custom properties for schema registry HOT 4
- Schema registry aborts after startup HOT 7
- Isit possible to use with Java? HOT 1
- how to access the schema registry server in test? HOT 1
- Publish 6.1.1 HOT 1
- Please publish version 6.2.0 HOT 1
- Schema Registry startup error HOT 3
- Can't Connect to schema-registry. HOT 2
- Custom Schema Registry Port not working HOT 2
- Not able to start the kafka broker HOT 4
- Non-breaking Wakeupexception on stop
- Incompatibility between versions of Confluent Platform and Kafka HOT 1
- Enable Basic and Bearer REST authentication HOT 1
- I am not able to run different specs using the same embedded Kafka HOT 6
- Release 7.3.0 version? HOT 1
- New version HOT 3
- Create 7.5.2 release HOT 2
- Version 7.6.1 uses scala 3.4.1 HOT 3
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from embedded-kafka-schema-registry.