AHeise opened a new pull request, #258: URL: https://github.com/apache/flink-connector-kafka/pull/258
The existing headers metadata key (MAP<STRING, BYTES>) silently drops duplicate header keys and loses insertion order, since iteration into a HashMap lets the last value win. The new multi-headers key exposes headers as ARRAY<ROW<name STRING, value BYTES>>, preserving wire order and duplicate keys faithfully on both source and sink sides. The two keys are mutually exclusive on the write path: declaring both in the same table schema is rejected at planning time with a ValidationException. Null header values are preserved; null header keys throw IllegalArgumentException since the Kafka protocol does not permit them. -- 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]
