Merge pull request #23544 from gungoren/main

Add aws_mskconnect_connector resource
hashicorp · Mar 25, 2022 · d92876f · d92876f
2 parents a38f0ef + 56880a7
commit d92876f
Show file tree

Hide file tree

Showing 27 changed files with 2,865 additions and 300 deletions.
diff --git a/.changelog/23544.txt b/.changelog/23544.txt
@@ -0,0 +1,11 @@
+```release-note:enhancement
+resource/aws_mskconnect_custom_plugin: Implement resource Delete
+```
+
+```new-resource
+aws_mskconnect_connector
+```
+
+```new-data-source
+aws_mskconnect_connector
+```
diff --git a/internal/provider/provider.go b/internal/provider/provider.go
@@ -679,6 +679,7 @@ func Provider() *schema.Provider {
 			"aws_msk_configuration": kafka.DataSourceConfiguration(),
 			"aws_msk_kafka_version": kafka.DataSourceVersion(),
 
+			"aws_mskconnect_connector":            kafkaconnect.DataSourceConnector(),
 			"aws_mskconnect_custom_plugin":        kafkaconnect.DataSourceCustomPlugin(),
 			"aws_mskconnect_worker_configuration": kafkaconnect.DataSourceWorkerConfiguration(),
 
@@ -1514,6 +1515,7 @@ func Provider() *schema.Provider {
 			"aws_msk_configuration":            kafka.ResourceConfiguration(),
 			"aws_msk_scram_secret_association": kafka.ResourceScramSecretAssociation(),
 
+			"aws_mskconnect_connector":            kafkaconnect.ResourceConnector(),
 			"aws_mskconnect_custom_plugin":        kafkaconnect.ResourceCustomPlugin(),
 			"aws_mskconnect_worker_configuration": kafkaconnect.ResourceWorkerConfiguration(),
 

diff --git a/internal/service/kafka/sweep.go b/internal/service/kafka/sweep.go
@@ -19,6 +19,9 @@ func init() {
 	resource.AddTestSweepers("aws_msk_cluster", &resource.Sweeper{
 		Name: "aws_msk_cluster",
 		F:    sweepClusters,
+		Dependencies: []string{
+			"aws_mskconnect_connector",
+		},
 	})
 
 	resource.AddTestSweepers("aws_msk_configuration", &resource.Sweeper{