You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@nifi.apache.org by "ASF subversion and git services (Jira)" <ji...@apache.org> on 2022/03/08 11:43:00 UTC
[jira] [Commented] (NIFI-9771) ConsumeKafkaRecord_2_6 verification should fail if Record Reader produces no records
[ 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 <jg...@gmail.com>
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)