Andre Couple of questions 1. Since KafkaPublisher class exists in all 3 Kafka processors (0.9 and 0.10 Kafka clients) under the same package name, which one does it happen in? I am assuming its intermittent. 2. How often does it happen?
My suspicion is that this test is using embedded Kafka together with NiFi test mocks and there may be slight possibility of a timing issue under the load of the build which means the test may need to be tuned. But if this test fails on 0.10 only it could also mean that we may need to look a little deeper (since I can’t remember seeng this failure yet) which could relate to some of the changes in Kafka 10 clients Cheers Oleg > On Sep 11, 2016, at 8:02 AM, Andre F de Miranda <af...@fucs.org> wrote: > > Hi there, > > is anyone else having frequent errors on some of the Kafka processors? > > Tests run: 6, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 22.248 sec > <<< FAILURE! - in org.apache.nifi.processors.kafka.pubsub.KafkaPublisherTest > validateSuccessfulSendAsDelimited(org.apache.nifi.processors.kafka.pubsub.KafkaPublisherTest) > Time elapsed: 1.413 sec <<< ERROR! > kafka.consumer.ConsumerTimeoutException: null > at kafka.consumer.ConsumerIterator.makeNext(ConsumerIterator.scala:69) > at kafka.consumer.ConsumerIterator.makeNext(ConsumerIterator.scala:33) > at kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) > at kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) > at kafka.utils.IteratorTemplate.next(IteratorTemplate.scala:38) > at kafka.consumer.ConsumerIterator.next(ConsumerIterator.scala:46) > at > org.apache.nifi.processors.kafka.pubsub.KafkaPublisherTest.validateSuccessfulSendAsDelimited(KafkaPublisherTest.java:115) > > It seems to happen only (or at least more frequently) when build is > performed with -T 2.0C > > > Cheers
