Comments (3)
Error was totally unrelated but because it existed it diverted my attention from the real problem.
My pipeline builds state and I had to disable caching in order to speed up producing new messages by setting:
StreamsConfig.CACHE_MAX_BYTES_BUFFERING_CONFIG -> "0".asInstanceOf[AnyRef],
StreamsConfig.COMMIT_INTERVAL_MS_CONFIG -> "100".asInstanceOf[AnyRef]
After applying this tests worked, again, nothing to do with the original errors.
from embedded-kafka-schema-registry.
Hi @robvadai , those warnings are a well known issue, but they cause no harm.
The only reference to WakeupException I could find is this. Does it happen regularly? Could the SR die unexpectedly before the test is over or right after?
from embedded-kafka-schema-registry.
Hi @francescopellegrini ,
I was using your library happily so far and never seen this error. I have a multi-project Gradle project where in one of my subprojects tests work with no problem at all. In another subproject I have the above error. Even when I run it in IntelliJ so it's not an issue because of 2 tests running in the same time.
It may be triggered by a hidden error in my opinion, so what I'm going to do is publish plain string messages and try to eliminate that it's my code. As I said in other projects the library works.
I just though I'll raise it if anyone else experienced this.
Not sure if it's maybe a timeout configuration, ie. would it be possible to increase some timeouts perhaps?
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
- Can't Connect to schema-registry. HOT 2
- Embedded Kafka Problems. HOT 7
- 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.