diff --git a/core/src/test/scala/integration/kafka/api/AdminClientIntegrationTest.scala b/core/src/test/scala/integration/kafka/api/AdminClientIntegrationTest.scala index 306bcb5fb91..a8d317c2fdf 100644 --- a/core/src/test/scala/integration/kafka/api/AdminClientIntegrationTest.scala +++ b/core/src/test/scala/integration/kafka/api/AdminClientIntegrationTest.scala @@ -740,7 +740,6 @@ class AdminClientIntegrationTest extends IntegrationTestHarness with Logging { try { altered = alterResult.values.get(topic2).get } catch { - case e: ExecutionException => case e: ExecutionException => assertTrue(e.getCause.isInstanceOf[InvalidPartitionsException]) assertEquals("Topic currently has 3 partitions, which is higher than the requested 2.", e.getCause.getMessage)