Comments (2)
Was thinking about this one a bit more. I personally don't like a sort of "registerExceptionHandler" or adding a parameter onDeserializationError
to plainStream
. Would it be sufficient to do the following:
- Fail the stream on deserialization errors by default (current behavior)
- Clients that want to skip non-deserializable messages can use the existing
Deserializer.asTry
in combination with amapConcat
if desired. We can write some documentation on how to achieve this behavior.
from zio-kafka.
Implemented in #89
from zio-kafka.
Related Issues (20)
- Avoid orDie's in transactional producer HOT 1
- Transaction support with cooperative rebalancing
- Reduce Set usage where possible
- Consumer block the app from shutting down HOT 11
- Optimistic prefetching HOT 1
- Check performance with zio 2.0.12's optimized aggregateAsyncWithin HOT 3
- [Idea] Split the runloop in different "behaviours"
- Deadlock with parallel processing of single partition stream HOT 16
- Discussion: Trying to understand the motivations for the Serializer API HOT 5
- People using the Consumer to do something else than consume will experience a `RunloopTimeout` HOT 1
- Allow modifying broker properties in zio-kafka-testkit HOT 3
- Update zio-quickstart-kafka example HOT 3
- Replace runloop timout with per stream halting detection HOT 1
- 2.3.x increases latency for consumed messages HOT 13
- OOM Exception in version 2.3.1 HOT 9
- [Idea] pause/resume/stop Stream and remove `stopConsumption` HOT 5
- Cannot start any of zio-kafka clients with security.protocol = SASL_PLAINTEXT when one of Kafka nodes is down
- Runloop crash causes indefinite hanging HOT 2
- BindExceptions when testing multi-module projects using ZIO Kafka Testkit HOT 8
- Duplicate events appear when using single Consumer with multiple subscriptions HOT 21
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.