[NIFI-4290] PublishKafkaRecord_0_10: failed to process due to java.lang.NullPointerException

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.4.0
• Fix Version/s: 1.4.0
• Component/s: Extensions
• Environment: NiFi 1.4 Master; Confluent Kafka 3.2
• Assignee: Mark Payne
• Reporter: Mayank Rathi
• Created: 12/Aug/17 03:01
• Updated: 12/Sep/17 01:43
• Resolved: 12/Sep/17 01:43

Description

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!!

Issue Links

• links to: GitHub Pull Request #2083