Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Duplicate
-
None
-
None
-
None
-
None
Description
Sometimes, while running mvn clean install exception comes:
NotificationHookConsumerKafkaTest.testConsumerConsumesNewMessageWithAutoCommitDisabled and NotificationHookConsumerKafkaTest.testConsumerRemainsAtSameMessageWithAutoCommitEnabled tests fail, The exception seen is 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 org.apache.atlas.kafka.KafkaConsumer.hasNext(KafkaConsumer.java:69) at org.apache.atlas.notification.NotificationHookConsumerKafkaTest.consumeOneMessage(NotificationHookConsumerKafkaTest.java:114) at org.apache.atlas.notification.NotificationHookConsumerKafkaTest.testConsumerConsumesNewMessageWithAutoCommitDisabled(NotificationHookConsumerKafkaTest.java:68)
After adding Thread.sleep(10000) in the NotificationHookConsumerKafkaTest.setup method after starting Kafka server, it passes.
Attachments
Issue Links
- Is contained by
-
ATLAS-912 Update to use Kafka 0.10.0.0 (from 0.9.0.0)
- Resolved