[NiFi-4290] Re: NiFi 1.4: PublishKafkaRecord_0_10: failed to process due to java.lang.NullPointerException

2017-08-14 Thread mayank rathi
Hello Joe, I have added all the details to NiFi-4290. Please let me know if you need any other information from my side. Thanks Mayank On Sat, Aug 12, 2017 at 12:00 AM, Joe Witt wrote: > Thanks for reporting the issue. It appears the NPE can occur if zero > records end up getting published an

Re: NiFi 1.4: PublishKafkaRecord_0_10: failed to process due to java.lang.NullPointerException

2017-08-11 Thread Joe Witt
Thanks for reporting the issue. It appears the NPE can occur if zero records end up getting published and it fails to lookup the schema because the message tracker is not yet initialized. So a couple things: 1) Verify the settings being used to lookup the schema. You can show the record reader,

Re: NiFi 1.4: PublishKafkaRecord_0_10: failed to process due to java.lang.NullPointerException

2017-08-11 Thread mayank rathi
Hello Joe, JIRA logged. https://issues.apache.org/jira/browse/NIFI-4290 Thanks!! On Fri, Aug 11, 2017 at 9:48 PM, Joe Witt wrote: > Hello > > Can you please file a jira and attach the logs to the jira. > > Thanks > Joe > > On Aug 11, 2017 6:23 PM, "mayank rathi" wrote: > > > Attached are the

Re: NiFi 1.4: PublishKafkaRecord_0_10: failed to process due to java.lang.NullPointerException

2017-08-11 Thread Joe Witt
Hello Can you please file a jira and attach the logs to the jira. Thanks Joe On Aug 11, 2017 6:23 PM, "mayank rathi" wrote: > Attached are the logs after setting processors in Debug mode. Here is the > flow: > > ExecuteSQL --> SplitAvro --> PublishKafkaRecord_0_10 > > Thanks!! > > On Fri, Aug

Re: NiFi 1.4: PublishKafkaRecord_0_10: failed to process due to java.lang.NullPointerException

2017-08-11 Thread mayank rathi
Attached are the logs after setting processors in Debug mode. Here is the flow: ExecuteSQL --> SplitAvro --> PublishKafkaRecord_0_10 Thanks!! On Fri, Aug 11, 2017 at 9:01 PM, mayank rathi wrote: > Hello All, > > I am moving data to Kafka using NiFi's PublishKafkaRecord processor. I am > using