Antony Stubbs
Antony Stubbs
Implemented as a draft extention of termainl retry handling: https://github.com/astubbs/parallel-consumer/pull/8 Extension of: - #242 Related: - https://github.com/confluentinc/parallel-consumer/issues/196 # Workaround Implement it yourself by producing to a dlq topic when you...
Atm, user has to implement the max retry functionality themselves, as documented here: [retries docs branch](https://github.com/confluentinc/parallel-consumer/tree/retry-docs#retries) This should be part of the system, as an option for a max retry...
Performance improvement for sending records. ### Checklist - [ ] Documentation (if applicable) - [ ] Changelog - [ ] consider blocking work retrieval during PM commit lock - move...
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
Get the dynamic fail fast patch committed, then update PC to use it. See: - https://github.com/awaitility/awaitility/issues/240 ``` waitAtMost(ofSeconds(30)) // dynamic reason support still waiting https://github.com/awaitility/awaitility/pull/193#issuecomment-873116199 // .failFast( () -> pc1.getFailureCause(),...
In key mode, if records of a given key exist in - multiple partitions of a topic (and those partitions are assigned to me) - or when subscribing to multiple...
When unexpected magic bytes occur, improve the feedback in the error shown to the user. Prompted from https://github.com/confluentinc/parallel-consumer/issues/326 - [ ] On magic byte error, log full metadata - [...
- Useful for when producing to a target cluster is mission critical - For situations where records could get timed out / expired in the producer and record loss is...
Produce and consume a 1GB message. ByteArrayOutputStream Not Blocked by, but would be good to have as well: - #395 Without straight production access - this feature would she limited...