nileshkumar3 opened a new pull request, #22983: URL: https://github.com/apache/kafka/pull/22983
When a key is evicted from the suppression buffer, InMemoryTimeOrderedKeyValueChangeBuffer writes a delete marker to the changelog so the topic can be compacted. That tombstone was written with no metadata at all (null timestamp and null headers), because the row and its ProcessorRecordContext were already discarded during evictWhile by the time commit() fires. Streams itself does not need this on the restore path (the key is passed through as raw Bytes), but it makes the tombstone impossible to interpret for anything else reading the changelog, and it is inconsistent with the header-aware stores, whose delete path keeps the record self-describing. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
