[
https://issues.apache.org/jira/browse/NIFI-2322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15404673#comment-15404673
]
ASF GitHub Bot commented on NIFI-2322:
--------------------------------------
Github user brosander commented on the issue:
https://github.com/apache/nifi/pull/741
@olegz I'm seeing failed tests
```
-------------------------------------------------------
T E S T S
-------------------------------------------------------
Running
org.apache.nifi.processors.kafka.pubsub.AbstractKafkaProcessorLifecycleTest
Tests run: 5, Failures: 0, Errors: 0, Skipped: 1, Time elapsed: 0.471 sec -
in org.apache.nifi.processors.kafka.pubsub.AbstractKafkaProcessorLifecycleTest
Running org.apache.nifi.processors.kafka.pubsub.ConsumeKafkaTest
Tests run: 3, Failures: 2, Errors: 0, Skipped: 0, Time elapsed: 0.062 sec
<<< FAILURE! - in org.apache.nifi.processors.kafka.pubsub.ConsumeKafkaTest
validateGetAllMessagesWithProvidedDemarcator(org.apache.nifi.processors.kafka.pubsub.ConsumeKafkaTest)
Time elapsed: 0.048 sec <<< FAILURE!
java.lang.AssertionError: expected:<1> but was:<0>
at org.junit.Assert.fail(Assert.java:88)
at org.junit.Assert.failNotEquals(Assert.java:834)
at org.junit.Assert.assertEquals(Assert.java:645)
at org.junit.Assert.assertEquals(Assert.java:631)
at
org.apache.nifi.processors.kafka.pubsub.ConsumeKafkaTest.validateGetAllMessagesWithProvidedDemarcator(ConsumeKafkaTest.java:140)
validateGetAllMessages(org.apache.nifi.processors.kafka.pubsub.ConsumeKafkaTest)
Time elapsed: 0.011 sec <<< FAILURE!
java.lang.AssertionError: expected:<6> but was:<0>
at org.junit.Assert.fail(Assert.java:88)
at org.junit.Assert.failNotEquals(Assert.java:834)
at org.junit.Assert.assertEquals(Assert.java:645)
at org.junit.Assert.assertEquals(Assert.java:631)
at
org.apache.nifi.processors.kafka.pubsub.ConsumeKafkaTest.validateGetAllMessages(ConsumeKafkaTest.java:102)
Running org.apache.nifi.processors.kafka.pubsub.KafkaPublisherTest
Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 7.382 sec -
in org.apache.nifi.processors.kafka.pubsub.KafkaPublisherTest
Running org.apache.nifi.processors.kafka.pubsub.PublishingContextTest
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.008 sec -
in org.apache.nifi.processors.kafka.pubsub.PublishingContextTest
Running org.apache.nifi.processors.kafka.pubsub.PublishKafkaTest
Tests run: 12, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.065 sec
- in org.apache.nifi.processors.kafka.pubsub.PublishKafkaTest
Results :
Failed tests:
ConsumeKafkaTest.validateGetAllMessages:102 expected:<6> but was:<0>
ConsumeKafkaTest.validateGetAllMessagesWithProvidedDemarcator:140
expected:<1> but was:<0>
```
> ConsumeKafka gets stuck (cannot be stopped)
> -------------------------------------------
>
> Key: NIFI-2322
> URL: https://issues.apache.org/jira/browse/NIFI-2322
> Project: Apache NiFi
> Issue Type: Bug
> Components: Extensions
> Affects Versions: 1.0.0
> Reporter: Haimo Liu
> Assignee: Oleg Zhurakousky
> Fix For: 1.0.0, 0.8.0
>
> Attachments: Screen Shot 2016-07-19 at 2.14.32 PM.png, Screen Shot
> 2016-07-19 at 2.14.48 PM.png
>
>
> If kafka broker path is invalid or inaccurate, ConsumeKafka processor can get
> stuck (concurrent tasks cannot be stopped in a clustered mode). Please refer
> to the images in the attachment. It appears that a configurable timeout
> property would potentially solve the problem.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
