sanghyeok An created KAFKA-21009:
------------------------------------
Summary: Consider introducing record header handling policies for
Kafka Streams stateful operations
Key: KAFKA-21009
URL: https://issues.apache.org/jira/browse/KAFKA-21009
Project: Kafka
Issue Type: Improvement
Reporter: sanghyeok An
Assignee: sanghyeok An
Stateful operations such as joins and aggregations may combine or retain
records from multiple inputs. Unlike one-to-one stateless operations, there may
not be an obvious set of headers to use for the output record.
Currently, header handling is determined by the behavior of each operator, and
applications do not have an explicit policy for controlling it.
We should consider whether Kafka Streams stateful operations could support
header handling policies such as:
* Retaining the existing behavior
* Ignoring or dropping headers
* Preserving headers from a selected input record
* Merging headers from multiple input records
This Jira is intended to capture the use case and evaluate whether such
policies would be useful. If pursued, the affected operators, exact policy set,
defaults, conflict handling, and consistency across caching and restoration
should be defined through a KIP.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
