update references in order to make this work with kafka 3.6.1 (#2)

* update references in order to make this work with kafka 3.6.1

* fix review comments

Author: spike83

CHANGELOG.md

@@ -3,3 +3,7 @@
 
 Initial version, client code adapted from Apache Kafka 3.3.1.  Allows JWT
 OAuth tokens to be fetch from Azure IMDS via HTTP GET.
+
+# 1.1-SNAPSHOT
+
+Updated to use Apache Kafka 3.6.1.

build.gradle

@@ -3,16 +3,16 @@ plugins {
 }
 
 group 'io.confluent.oauth'
-version '1.0-SNAPSHOT'
+version '1.1-SNAPSHOT'
 
 repositories {
     mavenCentral()
 }
 
 dependencies {
-    implementation group: 'org.apache.kafka', name: 'kafka-clients', version: '3.3.1'
-    implementation 'com.fasterxml.jackson.core:jackson-databind:2.13.3'
-    implementation 'org.bitbucket.b_c:jose4j:0.7.9'
+    implementation group: 'org.apache.kafka', name: 'kafka-clients', version: '3.6.1'
+    implementation 'com.fasterxml.jackson.core:jackson-databind:2.14.2'
+    implementation 'org.bitbucket.b_c:jose4j:0.9.3'
     implementation 'org.slf4j:slf4j-api:1.7.36'
     testImplementation 'org.junit.jupiter:junit-jupiter-api:5.8.1'
     testRuntimeOnly 'org.junit.jupiter:junit-jupiter-engine:5.8.1'

src/main/java/io/confluent/oauth/HttpAccessTokenRetriever.java

@@ -44,16 +44,17 @@
 import javax.net.ssl.SSLSocketFactory;
 import org.apache.kafka.common.KafkaException;
 
-import org.apache.kafka.common.security.oauthbearer.secured.AccessTokenRetriever;
-import org.apache.kafka.common.security.oauthbearer.secured.Retry;
-import org.apache.kafka.common.security.oauthbearer.secured.UnretryableException;
+
+import org.apache.kafka.common.security.oauthbearer.internals.secured.AccessTokenRetriever;
+import org.apache.kafka.common.security.oauthbearer.internals.secured.Retry;
+import org.apache.kafka.common.security.oauthbearer.internals.secured.UnretryableException;
 import org.apache.kafka.common.utils.Utils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 /**
  * <code>HttpAccessTokenRetriever</code> is an {@link AccessTokenRetriever} copied and derived from Apacha Kafka
- * {@link org.apache.kafka.common.security.oauthbearer.secured.HttpAccessTokenRetriever}.
+ * {@link org.apache.kafka.common.security.oauthbearer.internals.secured.HttpAccessTokenRetriever}.
  *
  * This version is designed to work with Azure Managed Identities via the link-local Instance Metadata Service (IMDS).
  * This service does not require authentication, and while an id/secret config is required, it is ignored.  Other

src/main/java/io/confluent/oauth/azure/managedidentity/OAuthBearerLoginCallbackHandler.java

@@ -43,7 +43,8 @@
 import org.apache.kafka.common.security.oauthbearer.OAuthBearerToken;
 import org.apache.kafka.common.security.oauthbearer.OAuthBearerTokenCallback;
 import org.apache.kafka.common.security.oauthbearer.internals.OAuthBearerClientInitialResponse;
-import org.apache.kafka.common.security.oauthbearer.secured.*;
+import org.apache.kafka.common.security.oauthbearer.OAuthBearerValidatorCallbackHandler;
+import org.apache.kafka.common.security.oauthbearer.internals.secured.*;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;