Comments (5)
I have my own test-kit based on the original utils in test. I extended with a couple more things useful for my own usages. Perhaps the answer would be to extend that and eventually when we are happy enough with the result and it is generic enough extract that to its own module?
from zio-kafka.
@saraiva132 Is it open-source? I'd love to see your work.
from zio-kafka.
@mvillafuertem Sure. What did you have in mind?
from zio-kafka.
Hi again @iravid, I am not a ZIO expert like you, but first I thought about starting to create another implementation with TestContainer and testing your current test with this implementation, then splitting all this code into another module like ZLayers and add asserts, utils to create topic, groupId, Kafka cluster, etc. With everything related to infrastructure. I don't know if this is interesting for you.
from zio-kafka.
Now there is a test utils module. :)
If you need more stuff in it open a ticket, or add to this one maybe.
from zio-kafka.
Related Issues (20)
- .retry does not actually restart the stream HOT 3
- Throughput issue with multi-topic subscription HOT 18
- Zio-kafka-testkit causing compile errors due to incompatible dependencies HOT 8
- RejectedExecutionException: Unable to run zio.internal.FiberRuntime - During shutdown HOT 2
- Producer and consumer diagnostics HOT 4
- Can we configure the zio-kafka with IAM access control for MSK? HOT 1
- Consumer should be able to commit offset with metadata
- Unexpected behavior during graceful shutdown HOT 7
- Unnecessary jackson-databind dependency HOT 1
- Commit timeout HOT 14
- PartitionedStream hanging after stream consumption started HOT 10
- AdminClient creation: java.lang.NoSuchMethodError: java.nio.ByteBuffer.position HOT 7
- Should commitOrRetry also retry commit timeouts? HOT 1
- Slow (timeout) shutdown and rebalancing with `withRebalanceSafeCommits ` HOT 13
- `partitionsFor` method missing from `zio.kafka.producer.Producer` HOT 5
- Make consumer metric collection more configurable HOT 3
- import socket ip='10.10.10.128' for port in range(1,100): try: s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) s.settimeout(5.0) s.connect((ip,port)) response = s.recv(1024) print(str(port),": open : Banner :",response.decode()) except socket.timeout as t: if(port==80): httpMessage = "GET / HTTP/1.0\r\n\r\n" s.send(httpMessage.encode()) httpRcv = s.recv(1024) print(str(port),": open : Banner :",httpRcv.decode()) else: print(str(port),": use different method") except Exception as e: #print(str(port),": closed : reason :",str(e)) pass finally: s.close()
- Possible to use a Scala 3 version of embedded-kafka? HOT 2
- Add support for embedded-kafka-schema-registry to the testkit HOT 4
- Consumer hanging indefinitely HOT 1
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 zio-kafka.