[NIFI-2670] ConsumeKafka should support a configurable option for how to encode kafka key as attribute - ASF JIRA

Attach files

Attach Screenshot

Voters

Watch issue

Watchers

Create sub-task

Link

Clone

Update Comment Author

Replace String in Comment

Update Comment Visibility

Delete Comments

XML

Word

Printable

JSON

Details

Type: Bug
Status: Resolved
Priority: Critical
Resolution: Fixed
Affects Version/s: None
Fix Version/s: 1.0.0
Component/s: Extensions
Labels:
None

Description

Previously, ConsumeKafka / GetKafka added the kafka key as an attribute to the flowfile, assuming that the key was in UTF-8 format. Recently, this was changed to use a hex encoding. This could break flows, as it is not backward compatible. We should instead make this a configurable option with the default being UTF-8 Encoded.