[ 
https://issues.apache.org/jira/browse/NIFI-9771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502880#comment-17502880
 ] 

ASF subversion and git services commented on NIFI-9771:
-------------------------------------------------------

Commit e6229ab938571f5339805797b6a6ffeebcfad652 in nifi's branch 
refs/heads/main from Mark Payne
[ https://gitbox.apache.org/repos/asf?p=nifi.git;h=e6229ab ]

NIFI-9771: When a Kafka record is obtained during config verification, we 
should produce an invalid response if the Record Reader is not able to produce 
any records from it

Signed-off-by: Joe Gresock <[email protected]>

This closes #5847.


> ConsumeKafkaRecord_2_6 verification should fail if Record Reader produces no 
> records
> ------------------------------------------------------------------------------------
>
>                 Key: NIFI-9771
>                 URL: https://issues.apache.org/jira/browse/NIFI-9771
>             Project: Apache NiFi
>          Issue Type: Bug
>          Components: Extensions
>            Reporter: Mark Payne
>            Assignee: Mark Payne
>            Priority: Major
>          Time Spent: 10m
>  Remaining Estimate: 0h
>
> I configured a ConsumeKafkaRecord_2_6 processor. I then used a Record Reader 
> that was meant to parse logs but pointed it at a topic containing JSON. I 
> then performed verification.
> There were no failures, as the Record Reader simply skips any records that 
> don't match the expected format. This should cause the processor's 
> verification to instead fail, since there was a Kafka message that produced 
> no Record from the RecordReader.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

Reply via email to