[
https://issues.apache.org/jira/browse/NIFI-9938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Witt updated NIFI-9938:
---------------------------
Fix Version/s: 1.16.1
> Correct error message for PublishKafkaRecord_2_6 and PublishKafka_2_6
> -------------------------------------------------------------------------
>
> Key: NIFI-9938
> URL: https://issues.apache.org/jira/browse/NIFI-9938
> Project: Apache NiFi
> Issue Type: Improvement
> Components: Core Framework
> Affects Versions: 1.15.0, 1.16.0, 1.15.1, 1.15.2, 1.15.3, 1.16.1
> Reporter: RAVINARAYAN SINGH
> Priority: Major
> Labels: bulletins
> Fix For: 1.17.0, 1.16.1
>
> Time Spent: 0.5h
> Remaining Estimate: 0h
>
> I am trying to read bulletin and I have observed two kind of message like
> below, one has bulletinFlowFileUuid and other won't have (as i notice they
> have uuid in bulletin message )
> {code:java}
> {
> "objectId" : "133daa29-c7a2-4e27-8280-93515afe21e8",
> "platform" : "nifi",
> "bulletinId" : 73,
> "bulletinCategory" : "Log Message",
> "bulletinGroupId" : "0180100d-8831-1705-c91e-fcf56119b794",
> "bulletinGroupName" : "xxxx",
> "bulletinGroupPath" : "xxxx",
> "bulletinLevel" : "ERROR",
> "bulletinMessage" :
> "PublishKafkaRecord_2_6[id=8831175d-101e-1180-d015-af879f9a08a3] Failed to
> send
> StandardFlowFileRecord[uuid=a2ae7ce6-cc6a-431a-a07c-a27eae803574,claim=StandardContentClaim
> [resourceClaim=StandardResourceClaim[id=1650393486592-12, container=default,
> section=12], offset=0,
> length=1068652],offset=0,name=aadbb17b-a59d-4d54-9054-4b38afb939f3,size=1068652]
> to Kafka: org.apache.kafka.common.errors.RecordTooLargeException: The
> message is 1068740 bytes when serialized which is larger than 1048576, which
> is the value of the max.request.size configuration.",
> "bulletinSourceId" : "8831175d-101e-1180-d015-af879f9a08a3",
> "bulletinSourceName" : "PublishKafkaRecord_2_6",
> "bulletinSourceType" : "PROCESSOR",
> "bulletinTimestamp" : "2022-04-19T18:38:20.721Z"
> }
> {
> "objectId" : "8af0eda1-4911-471f-811c-f914f560496d",
> "platform" : "nifi",
> "bulletinId" : 70,
> "bulletinCategory" : "Log Message",
> "bulletinGroupId" : "8831179e-1014-1180-9473-af0432d259ad",
> "bulletinGroupName" : "BulletinPublisher",
> "bulletinGroupPath" : "NiFi Flow / BulletinPublisher",
> "bulletinLevel" : "ERROR",
> "bulletinMessage" :
> "EvaluateJsonPath[id=88311752-101e-1180-1783-1c1ccf760a91] FlowFile
> FlowFile[filename=441b9cc4-a8d3-4426-8dbb-0cd49de2bac2] did not have valid
> JSON content.",
> "bulletinSourceId" : "88311752-101e-1180-1783-1c1ccf760a91",
> "bulletinSourceName" : "EvaluateJsonPath",
> "bulletinSourceType" : "PROCESSOR",
> "bulletinTimestamp" : "2022-04-19T18:22:10.078Z",
> "bulletinFlowFileUuid" : "441b9cc4-a8d3-4426-8dbb-0cd49de2bac2"
> } {code}
--
This message was sent by Atlassian Jira
(v8.20.7#820007)