diff --git a/pom.xml b/pom.xml
index d019ee741..ca27435aa 100644
--- a/pom.xml
+++ b/pom.xml
@@ -5,7 +5,7 @@
     <parent>
         <groupId>io.confluent</groupId>
         <artifactId>common</artifactId>
-        <version>6.0.3</version>
+        <version>[7.9.0,7.9.1)</version>
     </parent>
 
     <groupId>io.confluent</groupId>
@@ -40,9 +40,8 @@
     <properties>
         <es.version>7.9.3</es.version>
         <hamcrest.version>1.3</hamcrest.version>
-        <mockito.version>2.28.2</mockito.version>
         <gson.version>2.8.6</gson.version>
-        <test.containers.version>1.15.3</test.containers.version>
+        <test.containers.version>1.16.3</test.containers.version>
         <kafka.connect.maven.plugin.version>0.11.1</kafka.connect.maven.plugin.version>
         <maven.release.plugin.version>2.5.3</maven.release.plugin.version>
         <hadoop.version>3.3.0</hadoop.version>
@@ -55,6 +54,8 @@
         <dependency.check.version>6.1.6</dependency.check.version>
         <confluent.maven.repo>http://packages.confluent.io/maven/</confluent.maven.repo>
         <commons.codec.version>1.15</commons.codec.version>
+        <confluent.version>[7.9.0,7.9.1)</confluent.version>
+        <kafka.test.version>7.8.0-ccs</kafka.test.version>
         <jackson.version>2.16.0</jackson.version>
         <dependency.check.skip>true</dependency.check.skip>
     </properties>
@@ -105,11 +106,6 @@
             <artifactId>jackson-dataformat-cbor</artifactId>
         </dependency>
         <!-- pin commons-codec for CVE -->
-        <dependency>
-            <groupId>commons-codec</groupId>
-            <artifactId>commons-codec</artifactId>
-            <version>1.15</version>
-        </dependency>
         <dependency>
             <groupId>org.apache.httpcomponents</groupId>
             <artifactId>httpclient</artifactId>
@@ -121,17 +117,6 @@
             <version>${gson.version}</version>
             <scope>test</scope>
         </dependency>
-        <dependency>
-            <groupId>org.apache.httpcomponents</groupId>
-            <artifactId>httpclient</artifactId>
-            <version>4.5.13</version>
-        </dependency>
-        <!-- Force commons-codec (httpclient transitive dependency) version to address CVE CCMSG-835 -->
-        <dependency>
-            <groupId>commons-codec</groupId>
-            <artifactId>commons-codec</artifactId>
-            <version>1.15</version>
-        </dependency>
         <dependency>
             <groupId>commons-codec</groupId>
             <artifactId>commons-codec</artifactId>
@@ -161,6 +146,11 @@
             </exclusions>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter-api</artifactId>
+            <scope>test</scope>
+        </dependency>
         <dependency>
             <groupId>org.apache.kafka</groupId>
             <artifactId>connect-runtime</artifactId>
@@ -169,12 +159,6 @@
             <type>test-jar</type>
             <scope>test</scope>
         </dependency>
-        <!-- Use a repackaged version of log4j with security patches. Default log4j v1.2 is a transitive dependency of connect-runtime, but it is excluded in common/pom.xml -->
-        <dependency>
-            <groupId>io.confluent</groupId>
-            <artifactId>confluent-log4j</artifactId>
-            <scope>test</scope>
-        </dependency>
         <dependency>
             <groupId>org.apache.kafka</groupId>
             <artifactId>connect-runtime</artifactId>
@@ -184,7 +168,15 @@
         <dependency>
             <groupId>org.apache.kafka</groupId>
             <artifactId>kafka-clients</artifactId>
-            <version>${kafka.version}</version>
+            <version>${kafka.test.version}</version>
+            <classifier>test</classifier>
+            <type>test-jar</type>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.kafka</groupId>
+            <artifactId>kafka-server-common</artifactId>
+            <version>${kafka.test.version}</version>
             <classifier>test</classifier>
             <type>test-jar</type>
             <scope>test</scope>
diff --git a/src/main/java/io/confluent/connect/elasticsearch/ConfigCallbackHandler.java b/src/main/java/io/confluent/connect/elasticsearch/ConfigCallbackHandler.java
index 1c2676604..bd7a90317 100644
--- a/src/main/java/io/confluent/connect/elasticsearch/ConfigCallbackHandler.java
+++ b/src/main/java/io/confluent/connect/elasticsearch/ConfigCallbackHandler.java
@@ -54,7 +54,7 @@
 import org.apache.http.nio.conn.ssl.SSLIOSessionStrategy;
 import org.apache.http.nio.reactor.ConnectingIOReactor;
 import org.apache.http.nio.reactor.IOReactorException;
-import org.apache.kafka.common.network.Mode;
+import org.apache.kafka.common.network.ConnectionMode;
 import org.apache.kafka.common.security.ssl.SslFactory;
 import org.apache.kafka.connect.errors.ConnectException;
 import org.elasticsearch.client.RestClientBuilder.HttpClientConfigCallback;
@@ -258,7 +258,7 @@ private void configureSslContext(HttpAsyncClientBuilder builder) {
    * Gets the SslContext for the client.
    */
   private SSLContext sslContext() {
-    SslFactory sslFactory = new SslFactory(Mode.CLIENT, null, false);
+    SslFactory sslFactory = new SslFactory(ConnectionMode.CLIENT, null, false);
     sslFactory.configure(config.sslConfigs());
 
     try {
diff --git a/src/test/java/io/confluent/connect/elasticsearch/ElasticsearchClientTest.java b/src/test/java/io/confluent/connect/elasticsearch/ElasticsearchClientTest.java
index d0e68dcbe..bd75b9627 100644
--- a/src/test/java/io/confluent/connect/elasticsearch/ElasticsearchClientTest.java
+++ b/src/test/java/io/confluent/connect/elasticsearch/ElasticsearchClientTest.java
@@ -723,7 +723,7 @@ public void testSsl() throws Exception {
     helperClient = null;
 
     container.close();
-    container = ElasticsearchContainer.fromSystemProperties();
+    container = ElasticsearchContainer.fromSystemProperties().withSslEnabled(false);
     container.start();
   }
 
diff --git a/src/test/java/io/confluent/connect/elasticsearch/integration/BaseConnectorIT.java b/src/test/java/io/confluent/connect/elasticsearch/integration/BaseConnectorIT.java
index bca626ed9..d36a179fb 100644
--- a/src/test/java/io/confluent/connect/elasticsearch/integration/BaseConnectorIT.java
+++ b/src/test/java/io/confluent/connect/elasticsearch/integration/BaseConnectorIT.java
@@ -15,6 +15,8 @@
 
 package io.confluent.connect.elasticsearch.integration;
 
+import java.util.HashMap;
+import java.util.Map;
 import java.util.Optional;
 import java.util.concurrent.TimeUnit;
 
@@ -41,8 +43,10 @@ public abstract class BaseConnectorIT {
   protected RestApp restApp;
 
   protected void startConnect() {
+    Map<String, String> workerProps = new HashMap<>();
+    workerProps.put("plugin.discovery","hybrid_warn");
     connect = new EmbeddedConnectCluster.Builder()
-        .name("elasticsearch-it-connect-cluster")
+        .name("elasticsearch-it-connect-cluster").workerProps(workerProps)
         .build();
 
     // start the clusters