Not knowing your use case, an option could be something along the lines of:
ConsumeKafka -> SplitRecord (to get one message = one flowfile) ->
EvaluateJSONPath, assuming JSON Record Writer before, to extract some
specific fields into flowfile attributes (like the uuid header), and
EvaluateJsonPath again to only keep the message as content of the
flowfile.

However, while a record based approach can be a bit more complex at
first, this is highly recommended from a performance PoV if you have a
use case with high throughput.

Thanks,
Pierre

Le mar. 3 févr. 2026 à 15:50, Schuler, Joachim / Kuehne + Nagel / Ham
MI-DA <[email protected]> a écrit :
>
> Hello Pierre,
>
> thanks for your proposal. I would like to confirm, that I was able to get a 
> demo working with:
> - Processing Strategy = RECORD
> - Output Strategy = Use Wrapper
>
> The resulting flow file has all headers inside, including the problematic 
> 'uuid'.
> I'm now playing with different options of "RecordReader" to find out what 
> might be suitable in our case.
> This will be a bit of a challenge, and it was the reason why we originally 
> preferred to have one FlowFile (no parsing, just pass on the binary data).
>
> Thanks again & best regards,
> - Joachim
>
>
> -----Ursprüngliche Nachricht-----
> Von: Pierre Villard <[email protected]>
> Gesendet: Dienstag, 3. Februar 2026 13:45
> An: [email protected]
> Cc: Schuler, Joachim / Kuehne + Nagel / Ham MI-DA 
> <[email protected]>
> Betreff: Re: ConsumeKafka processor does not allow to get access to Kafka 
> message header 'uuid'
>
> EXTERNAL EMAIL
>
> Hi Joachim,
>
> How are you configuring your ConsumeKafka processor?
> If using
> - Processing Strategy = RECORD
> - Output Strategy = Use Wrapper
>
> You should get all of the headers as part of the content of the FlowFile. If 
> you really need to have one FlowFile = one message (definitely not 
> recommended), you could use additional processors in the flow.
>
> Thanks,
> Pierre
>
>
> Kühne + Nagel (AG & Co.) KG
> Rechtsform: Kommanditgesellschaft, Bremen HRA 21928, USt-IdNr.: DE 812773878.
> Geschäftsleitung Kühne + Nagel (AG & Co.) KG: Tobias Jerschke (Vors.), Sven 
> Bauer, Daniel Becker, Martin Brinkmann, Lars-Olof Grün, Matthias Knicky, 
> Martin Schäfer, Lars Wedel.
> Persönlich haftende Gesellschafterin: Kühne & Nagel A.G., Rechtsform: 
> Aktiengesellschaft nach luxemburgischem Recht, HR-Nr.: B 18745, 
> Geschäftsführendes Verwaltungsratsmitglied: Markus Blanka-Graff.
>
> Wir arbeiten ausschließlich auf Grundlage der Allgemeinen Deutschen 
> Spediteurbedingungen 2017 (ADSp 2017). Hinweis: Die ADSp 2017 weichen in 
> Ziffer 23 hinsichtlich des Haftungshöchstbetrages für Güterschäden (§ 431 
> HGB) vom Gesetz ab, indem sie die Haftung bei multimodalen Transporten unter 
> Einschluss einer Seebeförderung und bei unbekanntem Schadenort auf 2 SZR/kg 
> und im Übrigen die Regelhaftung von 8,33 SZR/kg zusätzlich auf 1,25 Millionen 
> Euro je Schadenfall sowie 2,5 Millionen Euro je Schadenereignis, mindestens 
> aber 2 SZR/kg, beschränken. Die ADSp sind auf unserer Webseite als Download 
> erhältlich. Auf Anfrage senden wir Ihnen diese auch gerne zu.
  • ConsumeKafka proce... Schuler, Joachim / Kuehne + Nagel / Ham MI-DA via users
    • Re: ConsumeKa... Pierre Villard
      • AW: Consu... Schuler, Joachim / Kuehne + Nagel / Ham MI-DA via users
        • Re: C... Pierre Villard
          • A... Schuler, Joachim / Kuehne + Nagel / Ham MI-DA via users
            • ... Pierre Villard
              • ... Emanuel Oliveira
                • ... Pierre Villard
                • ... Schuler, Joachim / Kuehne + Nagel / Ham MI-DA via users
                • ... Schuler, Joachim / Kuehne + Nagel / Ham MI-DA via users

Reply via email to