[ https://issues.apache.org/jira/browse/KAFKA-10157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Kowshik Prakasam resolved KAFKA-10157. -------------------------------------- Resolution: Fixed > Multiple tests failed due to "Failed to process feature ZK node change event" > ----------------------------------------------------------------------------- > > Key: KAFKA-10157 > URL: https://issues.apache.org/jira/browse/KAFKA-10157 > Project: Kafka > Issue Type: Bug > Reporter: Anna Povzner > Assignee: Kowshik Prakasam > Priority: Major > > Multiple tests failed due to "Failed to process feature ZK node change > event". Looks like a result of merge of this PR: > [https://github.com/apache/kafka/pull/8680] > Note that running tests without `--info` gives output like this one: > {quote}Process 'Gradle Test Executor 36' finished with non-zero exit value 1 > {quote} > kafka.network.DynamicConnectionQuotaTest failed: > {quote} > kafka.network.DynamicConnectionQuotaTest > testDynamicConnectionQuota > STANDARD_OUT > [2020-06-11 20:52:42,596] ERROR [feature-zk-node-event-process-thread]: > Failed to process feature ZK node change event. The broker will eventually > exit. > (kafka.server.FinalizedFeatureChangeListener$ChangeNotificationProcessorThread:76) > java.lang.InterruptedException > at > java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.reportInterruptAfterWait(AbstractQueuedSynchronizer.java:2056) > at > java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2090) > at > java.base/java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:433) > at > kafka.server.FinalizedFeatureChangeListener$ChangeNotificationProcessorThread.$anonfun$doWork$1(FinalizedFeatureChangeListener.scala:147){quote} > > kafka.api.CustomQuotaCallbackTest failed: > {quote} [2020-06-11 21:07:36,745] ERROR > [feature-zk-node-event-process-thread]: Failed to process feature ZK node > change event. The broker will eventually exit. > (kafka.server.FinalizedFeatureChangeListener$ChangeNotificationProcessorThread:76) > java.lang.InterruptedException > at > java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.reportInterruptAfterWait(AbstractQueuedSynchronizer.java:2056) > at > java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2090) > at > java.base/java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:433) > at > kafka.server.FinalizedFeatureChangeListener$ChangeNotificationProcessorThread.$anonfun$doWork$1(FinalizedFeatureChangeListener.scala:147) > at > scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.scala:18) > at scala.util.control.Exception$Catch.apply(Exception.scala:227) > at > kafka.server.FinalizedFeatureChangeListener$ChangeNotificationProcessorThread.doWork(FinalizedFeatureChangeListener.scala:147) > at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96) > at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.scala:18) > at scala.util.control.Exception$Catch.apply(Exception.scala:227) > at > kafka.server.FinalizedFeatureChangeListener$ChangeNotificationProcessorThread.doWork(FinalizedFeatureChangeListener.scala:147) > at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96) > {quote} > > kafka.server.DynamicBrokerReconfigurationTest failed: > {quote} [2020-06-11 21:13:01,207] ERROR > [feature-zk-node-event-process-thread]: Failed to process feature ZK node > change event. The broker will eventually exit. > (kafka.server.FinalizedFeatureChangeListener$ChangeNotificationProcessorThread:76) > java.lang.InterruptedException > at > java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.reportInterruptAfterWait(AbstractQueuedSynchronizer.java:2056) > at > java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2090) > at > java.base/java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:433) > at > kafka.server.FinalizedFeatureChangeListener$ChangeNotificationProcessorThread.$anonfun$doWork$1(FinalizedFeatureChangeListener.scala:147) > at > scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.scala:18) > at scala.util.control.Exception$Catch.apply(Exception.scala:227) > at > kafka.server.FinalizedFeatureChangeListener$ChangeNotificationProcessorThread.doWork(FinalizedFeatureChangeListener.scala:147) > at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96) > {quote} > > -- This message was sent by Atlassian Jira (v8.3.4#803005)