When using Kafka Streams with headers-aware state stores, delete operations are recorded as tombstones in…
When using Kafka Streams with headers-aware state stores, delete operations are recorded as tombstones in…: a task in LegoFlow-SWE (Harbor dataset). This is especially problematic when key serialization mutates headers as a side-effect (for example, a custom key Serializer adding metadata headers…
The task
This is especially problematic when key serialization mutates headers as a side-effect (for example, a custom key Serializer adding metadata headers during `serialize`). For non‑delete updates, these header side‑effects are expected to be present on the changelog records, but for deletes (such as `remove(key)`,…
Part of Lego-X/LegoFlow-SWE.