[
https://issues.apache.org/jira/browse/NIFI-4290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16124436#comment-16124436
]
Joseph Witt commented on NIFI-4290:
-----------------------------------
[~markap14] looks like this case can happen when the publisher/lease has been
initialized but has not yet published any messages. It is during the first
publish that the inflightmessagetracker gets initialized for the first time yet
if this never gets called, which can happen if the schema is not found, then
the attempt to register the failure will fail due to this NPE. ..it appears.
Any reason we cannot initialize the tracker when we create the lease itself?
> PublishKafkaRecord_0_10: failed to process due to
> java.lang.NullPointerException
> --------------------------------------------------------------------------------
>
> Key: NIFI-4290
> URL: https://issues.apache.org/jira/browse/NIFI-4290
> Project: Apache NiFi
> Issue Type: Bug
> Components: Extensions
> Affects Versions: 1.4.0
> Environment: NiFi 1.4 Master
> Confluent Kafka 3.2
> Reporter: Mayank Rathi
> Priority: Minor
> Fix For: 1.4.0
>
> Attachments: nifi-app.log
>
>
> Hello All,
> I am moving data to Kafka using NiFi's PublishKafkaRecord processor. I am
> using ConfluentSchemaRegistry Controller service and getting below error:
> 2017-08-11 20:54:25,937 ERROR [Timer-Driven Process Thread-4]
> o.a.n.p.k.pubsub.PublishKafkaRecord_0_10
> PublishKafkaRecord_0_10[id=b3c03961-015d-1000-0946-79ccbe2ffbbd]
> PublishKafkaRecord_0_10[id=b3c03961-015d-1000-0946-79ccbe2ffbbd] failed to
> process due to java.lang.NullPointerException; rolling back session: {}
> java.lang.NullPointerException: null
> I do not see any error on Kafka side.
> Attached are the logs after setting processors in Debug mode. Here is the
> flow:
> ExecuteSQL --> SplitAvro --> PublishKafkaRecord_0_10
> Thanks!!
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
