[ https://issues.apache.org/jira/browse/ATLAS-803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Nixon Rodrigues updated ATLAS-803: ---------------------------------- Description: Sometimes, while running mvn clean install exception comes: {noformat} 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) {noformat} After adding Thread.sleep(10000) in the NotificationHookConsumerKafkaTest.setup method after starting Kafka server, it passes. was: Sometimes, while running mvn clean install exception comes: {noformat} 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) {noformat} > NotificationHookConsumerKafkaTest fails sometimes while running mvn clean > install > --------------------------------------------------------------------------------- > > Key: ATLAS-803 > URL: https://issues.apache.org/jira/browse/ATLAS-803 > Project: Atlas > Issue Type: Bug > Reporter: Nixon Rodrigues > Assignee: Hemanth Yamijala > > Sometimes, while running mvn clean install exception comes: > {noformat} > 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) > {noformat} > After adding Thread.sleep(10000) in the > NotificationHookConsumerKafkaTest.setup method after starting Kafka server, > it passes. -- This message was sent by Atlassian JIRA (v6.3.4#6332)