Comments (6)
Hi @ecastilla95 , just to make sure, are you importing EmbeddedKafka
class from the io.github.embeddedkafka.schemaregistry
package?
from embedded-kafka-schema-registry.
Yes, I am using
import io.github.embeddedkafka.schemaregistry.{EmbeddedKafka, EmbeddedKafkaConfig}
I end up creating a new Embedded Kafka for each test class, which I guess is an expensive operation so this is not ideal
from embedded-kafka-schema-registry.
We have a test which looks exactly like what you described, try and see if your code is any different.
from embedded-kafka-schema-registry.
I see that you are creating different configs in different tests:
here
and here
my question is, can we re-use the embedded kafka default config? (in an out-of-the-box style)
I guess it is kind of a non-issue since I can maybe extend a trait but I find it counter intuitive that we have to create it again and again but with different ports
from embedded-kafka-schema-registry.
Never mind, I have tried both creating a trait and an object, the first test class works perfectly but the second one fails due to the cluster stopping
from embedded-kafka-schema-registry.
can we re-use the embedded kafka default config?
You mean separate files? As long as they are not run concurrently, yes, since each one will start and stop the whole setup every time.
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
- 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
- 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.