RAVINARAYAN SINGH created NIFI-9938:
---------------------------------------
Summary: 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.16.1
Reporter: RAVINARAYAN SINGH
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)
