fixes #26
This is a first impl. It could be optimized further, but I assume bad data are rare and it already does the job as it is.
There is a potential issue with inflightSinkRecords referencing all in-flight records. In theory, this can +- double memory consumption. but we need the original SinkRecord so we can send it to DLQ.
This is implemented for the HTTP transport only, because the TCP transport cannot report issues properly.
fixes #26 This is a first impl. It could be optimized further, but I assume bad data are rare and it already does the job as it is.
There is a potential issue with
inflightSinkRecordsreferencing all in-flight records. In theory, this can +- double memory consumption. but we need the originalSinkRecordso we can send it to DLQ.This is implemented for the HTTP transport only, because the TCP transport cannot report issues properly.