diff --git a/ksqldb-rest-app/src/test/java/io/confluent/ksql/rest/integration/ClusterTerminationTest.java b/ksqldb-rest-app/src/test/java/io/confluent/ksql/rest/integration/ClusterTerminationTest.java
index fd1a06811671..0368f4cc19b7 100644
--- a/ksqldb-rest-app/src/test/java/io/confluent/ksql/rest/integration/ClusterTerminationTest.java
+++ b/ksqldb-rest-app/src/test/java/io/confluent/ksql/rest/integration/ClusterTerminationTest.java
@@ -178,8 +178,8 @@ public void shouldTerminateAllTopicsWithStarInBody() throws InterruptedException
         is(true)
     );
 
-    // should be the pageview and _confluent-command topic left
-    assertThat(TEST_HARNESS.getKafkaCluster().getTopics().size(), is(2));
+    // should on be the pageview topic left
+    assertThat(TEST_HARNESS.getKafkaCluster().getTopics().size(), is(1));
 
     // Then:
     shouldReturn50303or50304WhenTerminating();
diff --git a/ksqldb-rest-app/src/test/java/io/confluent/ksql/rest/integration/TransientQueryResourceCleanerIntTest.java b/ksqldb-rest-app/src/test/java/io/confluent/ksql/rest/integration/TransientQueryResourceCleanerIntTest.java
index 30bf62294f68..15c1ce096172 100644
--- a/ksqldb-rest-app/src/test/java/io/confluent/ksql/rest/integration/TransientQueryResourceCleanerIntTest.java
+++ b/ksqldb-rest-app/src/test/java/io/confluent/ksql/rest/integration/TransientQueryResourceCleanerIntTest.java
@@ -75,11 +75,10 @@ public class TransientQueryResourceCleanerIntTest {
     private static final String USER_TABLE = USER_DATA_PROVIDER.sourceName();
 
     // Persistent Topics:
-    // _confluent-command, // This topic is created by ce-kafka for LicenseStore
     // _confluent-ksql-default__command_topic,
     // PAGEVIEW_TOPIC,
     // USER_TOPIC
-    private static final int numPersistentTopics = 4;
+    private static final int numPersistentTopics = 3;
 
     // Transient Topics:
     // _confluent-ksql-default_transient_transient_PV_[0-9]\d*_[0-9]\d*-KafkaTopic_Right-Reduce-changelog
diff --git a/pom.xml b/pom.xml
index ed9a7e3fd2c6..07c6596513ec 100644
--- a/pom.xml
+++ b/pom.xml
@@ -455,12 +455,6 @@
                 <version>${io.confluent.schema-registry.version}</version>
             </dependency>
 
-            <dependency>
-                <groupId>io.confluent</groupId>
-                <artifactId>broker-plugins</artifactId>
-                <version>${kafka.version}</version>
-            </dependency>
-
             <!-- End Confluent dependencies -->
 
             <dependency>
@@ -751,10 +745,6 @@
             <groupId>io.confluent</groupId>
             <artifactId>logredactor</artifactId>
         </dependency>
-            <dependency>
-                <groupId>io.confluent</groupId>
-                <artifactId>broker-plugins</artifactId>
-            </dependency>
     </dependencies>
 
     <build>