Move the existing module files to the extensions repo. This module will contain the factory functions to be utilized by users and the cross lang expansion service.

fozzie15 · fozzie15 · commit 2f1fafe762e2 · 2025-09-29T21:37:40.000Z
diff --git a/sdks/java/extensions/kafka-factories/build.gradle b/sdks/java/extensions/kafka-factories/build.gradle
@@ -18,11 +18,11 @@
 
 plugins { id 'org.apache.beam.module' }
 applyJavaNature(
-        automaticModuleName: 'org.apache.beam.sdk.io.kafka.file.aware.factories',
+        automaticModuleName: 'org.apache.beam.sdk.extensions.kafka.factories',
         publish: 'False'
 )
 
-description = "Apache Beam :: SDKs :: Java :: IO :: Kafka :: File :: Aware :: Factories"
+description = "Apache Beam :: SDKs :: Java :: Extensions :: Kafka :: Factories"
 ext.summary = "Library to instantiate kafka clients with files from GCS or SecretManager."
 
 dependencies {
diff --git a/sdks/java/extensions/kafka-factories/src/main/java/org/apache/beam/sdk/extensions/kafka/factories/FileAwareFactoryFn.java b/sdks/java/extensions/kafka-factories/src/main/java/org/apache/beam/sdk/extensions/kafka/factories/FileAwareFactoryFn.java
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.beam.sdk.io.kafka.file.aware.factories;
+package org.apache.beam.sdk.extensions.kafka.factories;
 
 import com.google.cloud.secretmanager.v1.AccessSecretVersionResponse;
 import com.google.cloud.secretmanager.v1.SecretManagerServiceClient;
diff --git a/sdks/java/extensions/kafka-factories/src/main/java/org/apache/beam/sdk/extensions/kafka/factories/KerberosConsumerFactoryFn.java b/sdks/java/extensions/kafka-factories/src/main/java/org/apache/beam/sdk/extensions/kafka/factories/KerberosConsumerFactoryFn.java
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.beam.sdk.io.kafka.file.aware.factories;
+package org.apache.beam.sdk.extensions.kafka.factories;
 
 import java.io.File;
 import java.io.IOException;
diff --git a/sdks/java/extensions/kafka-factories/src/main/java/org/apache/beam/sdk/extensions/kafka/factories/package-info.java b/sdks/java/extensions/kafka-factories/src/main/java/org/apache/beam/sdk/extensions/kafka/factories/package-info.java
@@ -17,4 +17,4 @@
  */
 
 /** ConsumerFactoryFns for file paths that exist in GCS or Google SecretManager. */
-package org.apache.beam.sdk.io.kafka.file.aware.factories;
+package org.apache.beam.sdk.extensions.kafka.factories;
diff --git a/sdks/java/extensions/kafka-factories/src/test/java/org/apache/beam/sdk/io/kafka/file/aware/factories/FileAwareFactoryFnTest.java b/sdks/java/extensions/kafka-factories/src/test/java/org/apache/beam/sdk/io/kafka/file/aware/factories/FileAwareFactoryFnTest.java
diff --git a/sdks/java/extensions/kafka-factories/src/test/java/org/apache/beam/sdk/io/kafka/file/aware/factories/KerberosConsumerFactoryFnTest.java b/sdks/java/extensions/kafka-factories/src/test/java/org/apache/beam/sdk/io/kafka/file/aware/factories/KerberosConsumerFactoryFnTest.java
diff --git a/settings.gradle.kts b/settings.gradle.kts
@@ -18,14 +18,14 @@
 import com.gradle.enterprise.gradleplugin.internal.extension.BuildScanExtensionWithHiddenFeatures
 
 pluginManagement {
-  plugins {
-     id("org.javacc.javacc") version "3.0.3" // enable the JavaCC parser generator
-  }
+    plugins {
+        id("org.javacc.javacc") version "3.0.3" // enable the JavaCC parser generator
+    }
 }
 
 plugins {
-  id("com.gradle.develocity") version "3.19"
-  id("com.gradle.common-custom-user-data-gradle-plugin") version "2.4.0"
+    id("com.gradle.develocity") version "3.19"
+    id("com.gradle.common-custom-user-data-gradle-plugin") version "2.2.1"
 }
 
 
@@ -36,32 +36,32 @@ val isGithubActionsBuild = arrayOf("GITHUB_REPOSITORY", "GITHUB_RUN_ID").all { S
 val isCi = isJenkinsBuild || isGithubActionsBuild
 
 develocity {
-  server = "https://develocity.apache.org"
-  projectId = "beam"
+    server = "https://develocity.apache.org"
+    projectId = "beam"
 
-  buildScan {
-    uploadInBackground = !isCi
-    publishing.onlyIf { it.isAuthenticated }
-    obfuscation {
-      ipAddresses { addresses -> addresses.map { "0.0.0.0" } }
+    buildScan {
+        uploadInBackground = !isCi
+        publishing.onlyIf { it.isAuthenticated }
+        obfuscation {
+            ipAddresses { addresses -> addresses.map { "0.0.0.0" } }
+        }
     }
-  }
 }
 
 buildCache {
-  local {
-    isEnabled = true
-  }
-  remote<HttpBuildCache> {
-    url = uri("https://beam-cache.apache.org/cache/")
-    isAllowUntrustedServer = false
-    credentials {
-      username = System.getenv("GRADLE_ENTERPRISE_CACHE_USERNAME")
-      password = System.getenv("GRADLE_ENTERPRISE_CACHE_PASSWORD")
+    local {
+        isEnabled = true
+    }
+    remote<HttpBuildCache> {
+        url = uri("https://beam-cache.apache.org/cache/")
+        isAllowUntrustedServer = false
+        credentials {
+            username = System.getenv("GRADLE_ENTERPRISE_CACHE_USERNAME")
+            password = System.getenv("GRADLE_ENTERPRISE_CACHE_PASSWORD")
+        }
+        isEnabled = !System.getenv("GRADLE_ENTERPRISE_CACHE_USERNAME").isNullOrBlank()
+        isPush = isCi && !System.getenv("GRADLE_ENTERPRISE_CACHE_USERNAME").isNullOrBlank()
     }
-    isEnabled = !System.getenv("GRADLE_ENTERPRISE_CACHE_USERNAME").isNullOrBlank()
-    isPush = isCi && !System.getenv("GRADLE_ENTERPRISE_CACHE_USERNAME").isNullOrBlank()
-  }
 }
 
 rootProject.name = "beam"
@@ -186,6 +186,7 @@ include(":sdks:java:extensions:kryo")
 include(":sdks:java:extensions:google-cloud-platform-core")
 include(":sdks:java:extensions:jackson")
 include(":sdks:java:extensions:join-library")
+include(":sdks:java:extensions:kafka-factories")
 include(":sdks:java:extensions:ml")
 include(":sdks:java:extensions:ordered")
 include(":sdks:java:extensions:protobuf")
