Alaksiej Ščarbaty created NIFI-16026:
----------------------------------------
Summary: Write message headers as hexadecimal strings in
ConsumeKafka
Key: NIFI-16026
URL: https://issues.apache.org/jira/browse/NIFI-16026
Project: Apache NiFi
Issue Type: Improvement
Reporter: Alaksiej Ščarbaty
Assignee: Alaksiej Ščarbaty
h2. Problem
{{{}ConsumeKafka{}}}'s *Header Encoding* property is charset-only
({{{}Charset.forName(...){}}}, {{{}ConsumeKafka.java:197{}}}/{{{}:379{}}}).
Binary headers (e.g. little-endian Int64) are corrupted by UTF-8 decoding and
unrecoverable. The *Key Attribute Encoding* property already supports {{HEX}}
({{{}KeyEncoding{}}} enum), but headers have no binary-safe path.
h2. Ask
Make header format configurable to support either strings (according to the
provided charset in {*}Header Encoding{*}) or hex format for Kafka message
headers.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
