Mark Payne commented on NIFI-2903:

[~kurthung1224] This is a good find. I think that rather than sending to a 
'failure' relationship the FlowFile should still go to the 'success' 
relationship. The FlowFile would just have no content, but it would have the 
appropriate attribute for the message key. Do you agree? Is this something that 
you're interested in tackling & contributing back to the community?

> GetKafka cannot handle null value in Kafka offset cause NullPointerException
> ----------------------------------------------------------------------------
>                 Key: NIFI-2903
>                 URL: https://issues.apache.org/jira/browse/NIFI-2903
>             Project: Apache NiFi
>          Issue Type: Bug
>    Affects Versions: 1.0.0, 0.7.0
>            Reporter: Kurt Hung
> The GetKafka processor does not handle the condition of null value that 
> exists in Kafka offset, which would cause the processor hang on and generate 
> a NullPointerException after 30 sec. It's easy to reproduce this issue; I use 
> the kafka-python to insert a key-value pair ("abc", None), and create a 
> GetKafka processor to consume the topic I've created. This issue would happen 
> immediately, and moreover, the processor could't consume rest offsets.
> Temporary I customize a GetKafka processor for a "Failure" relationship to 
> handle null values exist in Kafka offset to prevent this issue.

This message was sent by Atlassian JIRA

Reply via email to