confluentinc / confluentinc/parallel-consumer
Handle deserialization exceptions thrown from the deserialiser
Open
- Dominant language
- Java
- Stars
- 299
- Forks
- 172
- PR merge metrics
- No merged PRs in 30d
Description
Workaround: use byte[],byte[] for key value types, use Serdes' to deserialise yourself in the processing function, throw a terminal failure if you want to skip the message.
see:
- #291
Contributor guide
No contributing guide indexed for this repository
Research direction
Start by reading the linked issue #291 and tracing the deserialization and processing entry points it identifies. The issue does not name a file or test; done should mean deserialization exceptions are handled by the library rather than requiring callers to use byte arrays and deserialize manually.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- java, kafka
- Domain
- stream-processing
- Issue type
- Bug
- Difficulty
- 4/5
- Estimated time
- 3-5 days
- Activity status
- Quiet
- Clarity
- Needs clarification
- Newbie friendliness
- 35/100