diff --git a/flink-connector/flink-connector-gcp-pubsub/pom.xml b/flink-connector/flink-connector-gcp-pubsub/pom.xml
index f56c6e7b..f05a6538 100644
--- a/flink-connector/flink-connector-gcp-pubsub/pom.xml
+++ b/flink-connector/flink-connector-gcp-pubsub/pom.xml
@@ -39,7 +39,7 @@
         </executions>
         <configuration>
           <protocArtifact>
-            com.google.protobuf:protoc:3.4.0:exe:${os.detected.classifier}
+            com.google.protobuf:protoc:3.25.3:exe:${os.detected.classifier}
           </protocArtifact>
           <pluginId>grpc-java</pluginId>
           <pluginArtifact>
diff --git a/flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/PubSubSink.java b/flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/PubSubSink.java
index c7c34980..e5d7eafe 100644
--- a/flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/PubSubSink.java
+++ b/flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/PubSubSink.java
@@ -34,6 +34,7 @@
 import java.io.IOException;
 import org.apache.flink.api.connector.sink2.Sink;
 import org.apache.flink.api.connector.sink2.SinkWriter;
+import org.apache.flink.api.connector.sink2.WriterInitContext;
 
 /**
  * Google Cloud Pub/Sub sink to publish messages to a Pub/Sub topic.
@@ -92,7 +93,7 @@ private Publisher createPublisher(TopicName topicName) throws IOException {
   }
 
   @Override
-  public SinkWriter<T> createWriter(InitContext initContext) throws IOException {
+  public SinkWriter<T> createWriter(WriterInitContext initContext) throws IOException {
     try {
       serializationSchema().open(initContext.asSerializationSchemaInitializationContext());
     } catch (Exception e) {
diff --git a/flink-connector/pom.xml b/flink-connector/pom.xml
index 1fad1dcf..29972b46 100644
--- a/flink-connector/pom.xml
+++ b/flink-connector/pom.xml
@@ -13,10 +13,10 @@
   </modules>
   <properties>
     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-    <java.version>11</java.version>
-    <flink.version>1.17.2</flink.version>
-    <maven.compiler.source>11</maven.compiler.source>
-    <maven.compiler.target>11</maven.compiler.target>
+    <java.version>17</java.version>
+    <flink.version>2.2.0</flink.version>
+    <maven.compiler.source>17</maven.compiler.source>
+    <maven.compiler.target>17</maven.compiler.target>
     <auto-value.version>1.11.0</auto-value.version>
   </properties>