[jira] [Assigned] (NIFI-15934) PublishAMQP should handle oversized FlowFiles and ignore empty AMQP header keys

["Michael W Moser (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/NIFI-15934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Michael W Moser reassigned NIFI-15934:
--------------------------------------

    Assignee: Claudio Mattioni

> PublishAMQP should handle oversized FlowFiles and ignore empty AMQP header keys
> -------------------------------------------------------------------------------
>
>                 Key: NIFI-15934
>                 URL: https://issues.apache.org/jira/browse/NIFI-15934
>             Project: Apache NiFi
>          Issue Type: Bug
>          Components: Extensions
>    Affects Versions: 2.9.0
>            Reporter: Claudio Mattioni
>            Assignee: Claudio Mattioni
>            Priority: Major
>              Labels: AMQP
>          Time Spent: 1h 40m
>  Remaining Estimate: 0h
>
> PublishAMQP currently reads FlowFile content into a byte array before publishing the AMQP message. Since Java arrays require an int-sized length, FlowFiles larger than Integer.MAX_VALUE cannot be published using this path and can fail with an unsafe cast or allocation behavior.
> PublishAMQP should detect FlowFiles larger than Integer.MAX_VALUE before attempting to allocate the message byte array, log an error, penalize the FlowFile, and route it to failure.
> In addition, AMQP header attributes parsed from FlowFile attributes can currently produce entries with empty header keys. Empty AMQP header keys should be ignored instead of being added to the headers map.
> Proposed changes:
> - Validate FlowFile size before byte-array extraction.
> - Route oversized FlowFiles to failure with penalization.
> - Use Math.toIntExact when converting FlowFile size to byte array length.
> - Ignore empty AMQP header keys when parsing header attributes.
> - Add test coverage for oversized FlowFiles and empty AMQP header keys.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)