DSP-24890 Adds DS Advanced Auth Client Plugin

Adds DataStax Advanced Auth Client Plugin with OIDC support.
Updates project to JDK 11 (currently minimum requirement for the Auth
Client Plugin) and removes checks for JDK 8.

Author: tiagomlalves

common/pom.xml

@@ -69,6 +69,10 @@
         </exclusion>
       </exclusions>
     </dependency>
+    <dependency>
+      <groupId>com.datastax.db</groupId>
+      <artifactId>db-advanced-auth-client-plugin</artifactId>
+    </dependency>
     <dependency>
       <groupId>org.apache.kafka</groupId>
       <artifactId>kafka-clients</artifactId>

common/src/main/java/com/datastax/oss/common/sink/state/LifeCycleManager.java

@@ -31,6 +31,8 @@
 import static com.datastax.oss.driver.api.core.config.DefaultDriverOption.SSL_TRUSTSTORE_PATH;
 
 import com.codahale.metrics.MetricRegistry;
+import com.datastax.db.driver.api.plugin.auth.OIDCClientCredentialsAuthProvider;
+import com.datastax.db.driver.api.plugin.config.OIDCDriverOption;
 import com.datastax.dse.driver.api.core.config.DseDriverOption;
 import com.datastax.dse.driver.internal.core.auth.DseGssApiAuthProvider;
 import com.datastax.oss.common.sink.AbstractSinkTask;
@@ -621,14 +623,20 @@ private static void processAuthenticatorConfig(
               AUTH_PROVIDER_SASL_PROPERTIES, ImmutableMap.of("javax.security.sasl.qop", "auth"))
           .withStringMap(DseDriverOption.AUTH_PROVIDER_LOGIN_CONFIGURATION, loginConfig);
     } else if (authConfig.getProvider() == AuthenticatorConfig.Provider.OIDC) {
-      /*
-      TODO: OidcApiAuthProvider.
-        configLoaderBuilder
-          .withClass(AUTH_PROVIDER_CLASS, OidcApiAuthProvider.class)
-          .withString(AUTH_PROVIDER_SERVICE, authConfig.getService())
-          ....
-       */
-      throw new RuntimeException("TODO: OIDC authentication is not supported yet.");
+      configLoaderBuilder
+          .withClass(AUTH_PROVIDER_CLASS, OIDCClientCredentialsAuthProvider.class)
+          .withString(
+              OIDCDriverOption.AUTH_PROVIDER_OIDC_ISSUER, authConfig.getOIDCIssuer().toString())
+          .withString(OIDCDriverOption.AUTH_PROVIDER_OIDC_CLIENT_ID, authConfig.getOIDCClientId())
+          .withString(
+              OIDCDriverOption.AUTH_PROVIDER_OIDC_CLIENT_SECRET, authConfig.getOIDCClientSecret())
+          .withBoolean(OIDCDriverOption.AUTH_PROVIDER_OIDC_USE_TLS, authConfig.getOIDCUseTLS())
+          .withString(
+              OIDCDriverOption.AUTH_PROVIDER_OIDC_TRUSTSTORE_PATH,
+              authConfig.getOIDCTruststorePath().toString())
+          .withString(
+              OIDCDriverOption.AUTH_PROVIDER_OIDC_TRUSTSTORE_PASSWORD,
+              authConfig.getOIDCTruststorePassword());
     }
   }
 

pom.xml

@@ -37,11 +37,12 @@
   <properties>
     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
-    <java.version>1.8</java.version>
-    <java.release.version>8</java.release.version>
+    <java.version>11</java.version>
+    <java.release.version>11</java.release.version>
     <kafka.connect.version>2.4.0</kafka.connect.version>
     <caffeine.version>2.6.2</caffeine.version>
     <oss.driver.version>4.16.0</oss.driver.version>
+    <datastax.advanced-auth-client-plugin.version>1.0.1-SNAPSHOT</datastax.advanced-auth-client-plugin.version>
     <dsbulk.version>1.10.0</dsbulk.version>
     <reactive-streams.version>1.0.3</reactive-streams.version>
     <guava.version>25.1-jre</guava.version>
@@ -155,6 +156,11 @@
         <artifactId>java-driver-shaded-guava</artifactId>
         <version>${guava.version}</version>
       </dependency>
+      <dependency>
+        <groupId>com.datastax.db</groupId>
+        <artifactId>db-advanced-auth-client-plugin</artifactId>
+        <version>${datastax.advanced-auth-client-plugin.version}</version>
+      </dependency>
       <dependency>
         <groupId>org.reactivestreams</groupId>
         <artifactId>reactive-streams</artifactId>
@@ -286,26 +292,6 @@ limitations under the License.]]></inlineHeader>
           <artifactId>license-maven-plugin</artifactId>
           <version>1.14</version>
         </plugin>
-        <plugin>
-          <groupId>org.codehaus.mojo</groupId>
-          <artifactId>animal-sniffer-maven-plugin</artifactId>
-          <version>1.16</version>
-          <executions>
-            <execution>
-              <id>check-jdk8</id>
-              <goals>
-                <goal>check</goal>
-              </goals>
-              <configuration>
-                <signature>
-                  <groupId>org.codehaus.mojo.signature</groupId>
-                  <artifactId>java18</artifactId>
-                  <version>1.0</version>
-                </signature>
-              </configuration>
-            </execution>
-          </executions>
-        </plugin>
         <plugin>
           <groupId>org.apache.maven.plugins</groupId>
           <artifactId>maven-shade-plugin</artifactId>
@@ -430,10 +416,6 @@ limitations under the License.]]></inlineHeader>
         <groupId>com.mycila</groupId>
         <artifactId>license-maven-plugin</artifactId>
       </plugin>
-      <plugin>
-        <groupId>org.codehaus.mojo</groupId>
-        <artifactId>animal-sniffer-maven-plugin</artifactId>
-      </plugin>
       <plugin>
         <artifactId>maven-compiler-plugin</artifactId>
       </plugin>

text/pom.xml

@@ -22,7 +22,7 @@
     <artifactId>dsbulk-codecs</artifactId>
     <groupId>com.datastax.oss</groupId>
     <version>1.10.0</version>
-    <relativePath />
+    <relativePath/>
   </parent>
   <groupId>com.datastax.oss</groupId>
   <version>1.0.16-SNAPSHOT</version>
@@ -120,13 +120,6 @@
           <target>8</target>
         </configuration>
       </plugin>
-      <plugin>
-        <groupId>org.codehaus.mojo</groupId>
-        <artifactId>animal-sniffer-maven-plugin</artifactId>
-        <configuration>
-          <skip>true</skip>
-        </configuration>
-      </plugin>
     </plugins>
   </build>
 </project>