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