confluentinc / confluentinc/parallel-consumer

Handle deserialization exceptions thrown from the deserialiser

Open
#304 1 comment 0 reactions 0 assignees View on GitHub
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

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.