diff --git a/core/src/test/scala/unit/kafka/log/AbstractLogCleanerIntegrationTest.scala b/core/src/test/scala/unit/kafka/log/AbstractLogCleanerIntegrationTest.scala index bff27006e287a..2a0af3773c562 100644 --- a/core/src/test/scala/unit/kafka/log/AbstractLogCleanerIntegrationTest.scala +++ b/core/src/test/scala/unit/kafka/log/AbstractLogCleanerIntegrationTest.scala @@ -25,10 +25,13 @@ import kafka.utils.{MockTime, Pool, TestUtils} import kafka.utils.Implicits._ import org.apache.kafka.common.TopicPartition import org.apache.kafka.common.utils.Utils +import org.apache.kafka.test.IntegrationTest import org.junit.After +import org.junit.experimental.categories.Category import scala.collection.mutable.ListBuffer +@Category(Array(classOf[IntegrationTest])) abstract class AbstractLogCleanerIntegrationTest { var cleaner: LogCleaner = _