feat: add kafka topic support

config/confluent_kafka_topic/config.go

@@ -0,0 +1,48 @@
+package confluent_kafka_topic
+
+import (
+	"fmt"
+
+	xpref "github.com/crossplane/crossplane-runtime/pkg/reference"
+	xpresource "github.com/crossplane/crossplane-runtime/pkg/resource"
+	"github.com/crossplane/upjet/pkg/config"
+	"github.com/crossplane/upjet/pkg/resource"
+)
+
+// Constants for custom Extractor function
+var (
+	selfPackagePath     = "github.com/crossplane-contrib/provider-confluent/config/confluent_kafka_topic"
+	extractResourceIDFn = selfPackagePath + ".ExtractResourceID()"
+)
+
+// Configure configures individual resources by adding custom ResourceConfigurators.
+func Configure(p *config.Provider) {
+	p.AddResourceConfigurator("confluent_kafka_topic", func(r *config.Resource) {
+		// We need to override the default group that upjet generated for
+		r.ShortGroup = "confluent"
+		r.UseAsync = true
+		r.Kind = "KafkaTopic"
+
+		// Allows us to reference managedResource ID via spec.forProvider.managedResource.id
+		r.References["kafka_cluster.id"] = config.Reference{
+			Type: "Cluster",
+		}
+
+		// Allows us to reference managedResource ID via spec.forProvider.principal.idSelector
+		r.References["principal"] = config.Reference{
+			Type:      "ServiceAccount",
+			Extractor: extractResourceIDFn,
+		}
+	})
+}
+
+func ExtractResourceID() xpref.ExtractValueFn {
+	return func(mr xpresource.Managed) string {
+		tr, ok := mr.(resource.Terraformed)
+		if !ok {
+			return ""
+		}
+
+		return fmt.Sprintf("User:%v", tr.GetID()) // append 'User:' infront of the service account ID when resolving 'principal' field.
+	}
+}

config/external_name.go

@@ -18,6 +18,7 @@ var ExternalNameConfigs = map[string]config.ExternalName{
 	"confluent_kafka_acl":               config.IdentifierFromProvider,
 	"confluent_role_binding":            config.IdentifierFromProvider,
 	"confluent_schema_registry_cluster": config.IdentifierFromProvider,
+	"confluent_kafka_topic":             config.IdentifierFromProvider,
 }
 
 // ExternalNameConfigurations applies all external name configs listed in the

config/generated.lst

@@ -1 +1 @@
-["confluent_api_key","confluent_environment","confluent_kafka_acl","confluent_kafka_cluster","confluent_kafka_cluster_config","confluent_role_binding","confluent_schema_registry_cluster","confluent_service_account"]
+["confluent_api_key","confluent_environment","confluent_kafka_acl","confluent_kafka_cluster","confluent_kafka_cluster_config","confluent_kafka_topic","confluent_role_binding","confluent_schema_registry_cluster","confluent_service_account"]