diff --git a/kcbq-connector/src/test/java/com/wepay/kafka/connect/bigquery/integration/BaseConnectorIT.java b/kcbq-connector/src/test/java/com/wepay/kafka/connect/bigquery/integration/BaseConnectorIT.java
index 7144a4b9..61652525 100644
--- a/kcbq-connector/src/test/java/com/wepay/kafka/connect/bigquery/integration/BaseConnectorIT.java
+++ b/kcbq-connector/src/test/java/com/wepay/kafka/connect/bigquery/integration/BaseConnectorIT.java
@@ -123,7 +123,7 @@ protected void startConnect() {
         WorkerConfig.PLUGIN_DISCOVERY_CONFIG, "HYBRID_WARN");
 
     Properties brokerProps = new Properties();
-    brokerProps.put(KafkaConfig.MessageMaxBytesProp(), 10 * 1024 * 1024);
+    brokerProps.put("message.max.bytes", 10 * 1024 * 1024);
 
     connect = new EmbeddedConnectCluster.Builder()
         .name("kcbq-connect-cluster")
diff --git a/pom.xml b/pom.xml
index e28fa6e6..d76faa6d 100644
--- a/pom.xml
+++ b/pom.xml
@@ -46,9 +46,9 @@
         <com.google.auto.value.version>1.10.2</com.google.auto.value.version>
         <confluent.version>7.6.0</confluent.version>
         <debezium.version>0.6.2</debezium.version>
-        <jackson.version>2.14.2</jackson.version>
+        <jackson.version>2.16.2</jackson.version>
         <jetty.version>9.4.56.v20240826</jetty.version>
-        <kafka.version>3.6.1</kafka.version>
+        <kafka.version>3.9.1</kafka.version>
         <kafka.scala.version>2.12</kafka.scala.version>
         <slf4j.version>1.7.26</slf4j.version>
         <caffeine.version>2.8.6</caffeine.version>