You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@nifi.apache.org by "Alaksiej Ščarbaty (Jira)" <ji...@apache.org> on 2026/06/17 13:46:00 UTC

[jira] [Created] (NIFI-16026) Write message headers as hexadecimal strings in ConsumeKafka

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)