[jira] [Commented] (NIFI-2445) PublishKafka sends flowfiles to 'success' if not authorized to write to topic
[ https://issues.apache.org/jira/browse/NIFI-2445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15405122#comment-15405122 ] ASF subversion and git services commented on NIFI-2445: --- Commit 7040b4b1d1c4f1b8e61cc5c8205e09876c0386c0 in nifi's branch refs/heads/0.x from [~ozhurakousky] [ https://git-wip-us.apache.org/repos/asf?p=nifi.git;h=7040b4b ] NIFI-2444 NIFI-2445 fixed PublishKafka - fixed the logging issue NIFI-2444 by ensuring the ProcessLog is added to KafkaPublisher - fixed KafkaPublisher's isAllAcked operation to ensure that it properly reports that the flow file has failed. - added additional test > PublishKafka sends flowfiles to 'success' if not authorized to write to topic > - > > Key: NIFI-2445 > URL: https://issues.apache.org/jira/browse/NIFI-2445 > Project: Apache NiFi > Issue Type: Bug > Components: Extensions >Reporter: Mark Payne >Assignee: Oleg Zhurakousky >Priority: Blocker > Fix For: 1.0.0, 0.8.0 > > > I have a PublishKafka processor configured to write to a kafka topic that I > am not authorized to write to (via PLAINTEXT_SASL configuration). When I > attempt to send a message to Kafka, I get a stack trace telling me that I am > not authorized but the FlowFile is still routed to 'success' -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (NIFI-2445) PublishKafka sends flowfiles to 'success' if not authorized to write to topic
[ https://issues.apache.org/jira/browse/NIFI-2445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15405088#comment-15405088 ] ASF subversion and git services commented on NIFI-2445: --- Commit 54549891e3c6fd6a3a625ec24facc0bd5de6d556 in nifi's branch refs/heads/master from [~ozhurakousky] [ https://git-wip-us.apache.org/repos/asf?p=nifi.git;h=5454989 ] NIFI-2444 NIFI-2445 fixed PublishKafka - fixed the logging issue NIFI-2444 by ensuring the ProcessLog is added to KafkaPublisher - fixed KafkaPublisher's isAllAcked operation to ensure that it properly reports that the flow file has failed. - added additional test This closes #758. > PublishKafka sends flowfiles to 'success' if not authorized to write to topic > - > > Key: NIFI-2445 > URL: https://issues.apache.org/jira/browse/NIFI-2445 > Project: Apache NiFi > Issue Type: Bug > Components: Extensions >Reporter: Mark Payne >Assignee: Oleg Zhurakousky >Priority: Blocker > Fix For: 1.0.0, 0.8.0 > > > I have a PublishKafka processor configured to write to a kafka topic that I > am not authorized to write to (via PLAINTEXT_SASL configuration). When I > attempt to send a message to Kafka, I get a stack trace telling me that I am > not authorized but the FlowFile is still routed to 'success' -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (NIFI-2445) PublishKafka sends flowfiles to 'success' if not authorized to write to topic
[ https://issues.apache.org/jira/browse/NIFI-2445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15404819#comment-15404819 ] Mark Payne commented on NIFI-2445: -- [~ozhurakousky] - I see that PR 761 references both NIFI-2444 and NIFI-2445. Does this mean that you're now in agreement that this is an issue? > PublishKafka sends flowfiles to 'success' if not authorized to write to topic > - > > Key: NIFI-2445 > URL: https://issues.apache.org/jira/browse/NIFI-2445 > Project: Apache NiFi > Issue Type: Bug > Components: Extensions >Reporter: Mark Payne >Assignee: Oleg Zhurakousky >Priority: Blocker > Fix For: 1.0.0, 0.8.0 > > > I have a PublishKafka processor configured to write to a kafka topic that I > am not authorized to write to (via PLAINTEXT_SASL configuration). When I > attempt to send a message to Kafka, I get a stack trace telling me that I am > not authorized but the FlowFile is still routed to 'success' -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (NIFI-2445) PublishKafka sends flowfiles to 'success' if not authorized to write to topic
[ https://issues.apache.org/jira/browse/NIFI-2445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402035#comment-15402035 ] Oleg Zhurakousky commented on NIFI-2445: I've also added test case to validate this specific exception. > PublishKafka sends flowfiles to 'success' if not authorized to write to topic > - > > Key: NIFI-2445 > URL: https://issues.apache.org/jira/browse/NIFI-2445 > Project: Apache NiFi > Issue Type: Bug > Components: Extensions >Reporter: Mark Payne >Assignee: Oleg Zhurakousky >Priority: Blocker > Fix For: 1.0.0, 0.8.0 > > > I have a PublishKafka processor configured to write to a kafka topic that I > am not authorized to write to (via PLAINTEXT_SASL configuration). When I > attempt to send a message to Kafka, I get a stack trace telling me that I am > not authorized but the FlowFile is still routed to 'success' -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (NIFI-2445) PublishKafka sends flowfiles to 'success' if not authorized to write to topic
[
https://issues.apache.org/jira/browse/NIFI-2445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402034#comment-15402034
]
Oleg Zhurakousky commented on NIFI-2445:
Mark, I am not sure that this is correct. I've just tested it and I do not see
any files going to SUCCESS since the exception during
_this.kafkaProducer.send(message)_ will be caught only at line:199 of
AbstractKafkaProcessor which does the following:
{code}
} catch (Throwable e) {
this.acceptTask = false;
session.rollback(true);
this.getLogger().error("{} failed to process due to {}; rolling
back session", new Object[] { this, e });
{code}
Please advise
> PublishKafka sends flowfiles to 'success' if not authorized to write to topic
> -
>
> Key: NIFI-2445
> URL: https://issues.apache.org/jira/browse/NIFI-2445
> Project: Apache NiFi
> Issue Type: Bug
> Components: Extensions
>Reporter: Mark Payne
>Assignee: Oleg Zhurakousky
>Priority: Blocker
> Fix For: 1.0.0, 0.8.0
>
>
> I have a PublishKafka processor configured to write to a kafka topic that I
> am not authorized to write to (via PLAINTEXT_SASL configuration). When I
> attempt to send a message to Kafka, I get a stack trace telling me that I am
> not authorized but the FlowFile is still routed to 'success'
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
[jira] [Commented] (NIFI-2445) PublishKafka sends flowfiles to 'success' if not authorized to write to topic
[ https://issues.apache.org/jira/browse/NIFI-2445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15401986#comment-15401986 ] Mark Payne commented on NIFI-2445: -- I also see this happen when the topic that I attempt to send to does not exist. > PublishKafka sends flowfiles to 'success' if not authorized to write to topic > - > > Key: NIFI-2445 > URL: https://issues.apache.org/jira/browse/NIFI-2445 > Project: Apache NiFi > Issue Type: Bug > Components: Extensions >Reporter: Mark Payne >Assignee: Oleg Zhurakousky >Priority: Blocker > Fix For: 1.0.0, 0.8.0 > > > I have a PublishKafka processor configured to write to a kafka topic that I > am not authorized to write to (via PLAINTEXT_SASL configuration). When I > attempt to send a message to Kafka, I get a stack trace telling me that I am > not authorized but the FlowFile is still routed to 'success' -- This message was sent by Atlassian JIRA (v6.3.4#6332)
