diff --git a/flink-formats/flink-avro-confluent-registry/pom.xml b/flink-formats/flink-avro-confluent-registry/pom.xml
index e8e68a15d6d99..7534d5a34bb07 100644
--- a/flink-formats/flink-avro-confluent-registry/pom.xml
+++ b/flink-formats/flink-avro-confluent-registry/pom.xml
@@ -32,7 +32,8 @@ under the License.
Flink : Formats : Avro confluent registry
- 7.5.3
+ 7.9.8
+ 3.9.2
@@ -162,6 +163,12 @@ under the License.
test
test-jar
+
+ org.apache.kafka
+ kafka-clients
+ ${kafka.compatibility.version}
+ test
+
diff --git a/flink-formats/flink-avro-confluent-registry/src/test/java/org/apache/flink/formats/avro/registry/confluent/CachedSchemaCoderProviderTest.java b/flink-formats/flink-avro-confluent-registry/src/test/java/org/apache/flink/formats/avro/registry/confluent/CachedSchemaCoderProviderTest.java
index 3e8f53cdf4701..0576a66765f22 100644
--- a/flink-formats/flink-avro-confluent-registry/src/test/java/org/apache/flink/formats/avro/registry/confluent/CachedSchemaCoderProviderTest.java
+++ b/flink-formats/flink-avro-confluent-registry/src/test/java/org/apache/flink/formats/avro/registry/confluent/CachedSchemaCoderProviderTest.java
@@ -112,6 +112,21 @@ void testThatBearerAuthIsInitializedForBearerAuthProperties() {
assertThat(bearerAuthCredentialProvider.getBearerToken(null)).isEqualTo(token);
}
+ @Test
+ void testThatOauthBearerAuthIsCompatibleWithKafkaClient39() {
+ Map configs = new HashMap<>();
+ configs.put("bearer.auth.credentials.source", "OAUTHBEARER");
+ configs.put("bearer.auth.issuer.endpoint.url", "https://issuer.example/token");
+ configs.put("bearer.auth.client.id", "registry-api");
+ configs.put("bearer.auth.client.secret", "secret");
+
+ CachedSchemaCoderProvider provider = initCachedSchemaCoderProvider(configs);
+ BearerAuthCredentialProvider bearerAuthCredentialProvider =
+ getBearerAuthFromProvider(provider);
+
+ assertThat(bearerAuthCredentialProvider).isNotNull();
+ }
+
private String getAbsolutePath(String path) throws URISyntaxException {
return CachedSchemaCoderProviderTest.class.getResource(path).toURI().getPath();
}
diff --git a/flink-formats/flink-sql-avro-confluent-registry/src/main/resources/META-INF/NOTICE b/flink-formats/flink-sql-avro-confluent-registry/src/main/resources/META-INF/NOTICE
index 239d7f3100f9b..b78031eae6ae9 100644
--- a/flink-formats/flink-sql-avro-confluent-registry/src/main/resources/META-INF/NOTICE
+++ b/flink-formats/flink-sql-avro-confluent-registry/src/main/resources/META-INF/NOTICE
@@ -11,12 +11,12 @@ This project bundles the following dependencies under the Apache Software Licens
- com.fasterxml.jackson.core:jackson-databind:2.21.3
- com.google.guava:guava:32.0.1-jre
- commons-io:commons-io:2.15.1
-- io.confluent:common-utils:7.5.3
-- io.confluent:kafka-schema-registry-client:7.5.3
+- io.confluent:common-utils:7.9.8
+- io.confluent:kafka-schema-registry-client:7.9.8
- org.apache.avro:avro:1.11.5
- org.apache.commons:commons-compress:1.26.0
- org.apache.commons:commons-lang3:3.18.0
-- org.apache.kafka:kafka-clients:7.5.3-ccs
+- org.apache.kafka:kafka-clients:7.9.8-ccs
- org.xerial.snappy:snappy-java:1.1.10.7
- org.yaml:snakeyaml:2.3