Add import examples for Kafka source tables

docs/resources/source_table_kafka.md

@@ -10,7 +10,56 @@ description: |-
 
 A Kafka source describes a Kafka cluster you want Materialize to read data from.
 
-
+## Example Usage
+
+```terraform
+resource "materialize_source_table_kafka" "kafka_source_table" {
+  name          = "kafka_source_table"
+  schema_name   = "public"
+  database_name = "materialize"
+
+  source {
+    name          = materialize_source_kafka.test_source_kafka.name
+    schema_name   = materialize_source_kafka.test_source_kafka.schema_name
+    database_name = materialize_source_kafka.test_source_kafka.database_name
+  }
+
+  upstream_name           = "terraform" # The kafka source topic name
+  include_key             = true
+  include_key_alias       = "message_key"
+  include_headers         = true
+  include_headers_alias   = "message_headers"
+  include_partition       = true
+  include_partition_alias = "message_partition"
+  include_offset          = true
+  include_offset_alias    = "message_offset"
+  include_timestamp       = true
+  include_timestamp_alias = "message_timestamp"
+
+
+  key_format {
+    text = true
+  }
+  value_format {
+    json = true
+  }
+
+  envelope {
+    upsert = true
+    upsert_options {
+      value_decoding_errors {
+        inline {
+          enabled = true
+          alias   = "decoding_error"
+        }
+      }
+    }
+  }
+
+  ownership_role = "mz_system"
+  comment        = "This is a test Kafka source table"
+}
+```
 
 <!-- schema generated by tfplugindocs -->
 ## Schema
@@ -320,3 +369,15 @@ Optional:
 
 - `database_name` (String) The schema_registry_connection database name. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set.
 - `schema_name` (String) The schema_registry_connection schema name. Defaults to `public`.
+
+## Import
+
+Import is supported using the following syntax:
+
+```shell
+# Source tables can be imported using the source table id:
+terraform import materialize_source_table_kafka.example_source_table_kafka <region>:<source_table_id>
+
+# Source id and information be found in the `mz_catalog.mz_tables` table
+# The region is the region where the database is located (e.g. aws/us-east-1)
+```

docs/resources/source_table_load_generator.md

@@ -70,8 +70,8 @@ Optional:
 Import is supported using the following syntax:
 
 ```shell
-# Source tables can be imported using the source id:
-terraform import materialize_source_table_load_generator.example_source_table_loadgen <region>:<source_id>
+# Source tables can be imported using the source table id:
+terraform import materialize_source_table_load_generator.example_source_table_loadgen <region>:<source_table_id>
 
 # Source id and information be found in the `mz_catalog.mz_tables` table
 # The region is the region where the database is located (e.g. aws/us-east-1)

docs/resources/source_table_mysql.md

@@ -77,8 +77,8 @@ Optional:
 Import is supported using the following syntax:
 
 ```shell
-# Source tables can be imported using the source id:
-terraform import materialize_source_table_mysql.example_source_table_mysql <region>:<source_id>
+# Source tables can be imported using the source table id:
+terraform import materialize_source_table_mysql.example_source_table_mysql <region>:<source_table_id>
 
 # Source id and information be found in the `mz_catalog.mz_tables` table
 # The region is the region where the database is located (e.g. aws/us-east-1)

docs/resources/source_table_postgres.md

@@ -75,8 +75,8 @@ Optional:
 Import is supported using the following syntax:
 
 ```shell
-# Source tables can be imported using the source id:
-terraform import materialize_source_table_postgres.example_source_table_postgres <region>:<source_id>
+# Source tables can be imported using the source table id:
+terraform import materialize_source_table_postgres.example_source_table_postgres <region>:<source_table_id>
 
 # Source id and information be found in the `mz_catalog.mz_tables` table
 # The region is the region where the database is located (e.g. aws/us-east-1)

examples/resources/materialize_source_table_kafka/import.sh

@@ -0,0 +1,5 @@
+# Source tables can be imported using the source table id:
+terraform import materialize_source_table_kafka.example_source_table_kafka <region>:<source_table_id>
+
+# Source id and information be found in the `mz_catalog.mz_tables` table
+# The region is the region where the database is located (e.g. aws/us-east-1)

examples/resources/materialize_source_table_kafka/resource.tf

@@ -0,0 +1,46 @@
+resource "materialize_source_table_kafka" "kafka_source_table" {
+  name          = "kafka_source_table"
+  schema_name   = "public"
+  database_name = "materialize"
+
+  source {
+    name          = materialize_source_kafka.test_source_kafka.name
+    schema_name   = materialize_source_kafka.test_source_kafka.schema_name
+    database_name = materialize_source_kafka.test_source_kafka.database_name
+  }
+
+  upstream_name           = "terraform" # The kafka source topic name
+  include_key             = true
+  include_key_alias       = "message_key"
+  include_headers         = true
+  include_headers_alias   = "message_headers"
+  include_partition       = true
+  include_partition_alias = "message_partition"
+  include_offset          = true
+  include_offset_alias    = "message_offset"
+  include_timestamp       = true
+  include_timestamp_alias = "message_timestamp"
+
+
+  key_format {
+    text = true
+  }
+  value_format {
+    json = true
+  }
+
+  envelope {
+    upsert = true
+    upsert_options {
+      value_decoding_errors {
+        inline {
+          enabled = true
+          alias   = "decoding_error"
+        }
+      }
+    }
+  }
+
+  ownership_role = "mz_system"
+  comment        = "This is a test Kafka source table"
+}

examples/resources/materialize_source_table_load_generator/import.sh

@@ -1,5 +1,5 @@
-# Source tables can be imported using the source id:
-terraform import materialize_source_table_load_generator.example_source_table_loadgen <region>:<source_id>
+# Source tables can be imported using the source table id:
+terraform import materialize_source_table_load_generator.example_source_table_loadgen <region>:<source_table_id>
 
 # Source id and information be found in the `mz_catalog.mz_tables` table
 # The region is the region where the database is located (e.g. aws/us-east-1)

examples/resources/materialize_source_table_mysql/import.sh

@@ -1,5 +1,5 @@
-# Source tables can be imported using the source id:
-terraform import materialize_source_table_mysql.example_source_table_mysql <region>:<source_id>
+# Source tables can be imported using the source table id:
+terraform import materialize_source_table_mysql.example_source_table_mysql <region>:<source_table_id>
 
 # Source id and information be found in the `mz_catalog.mz_tables` table
 # The region is the region where the database is located (e.g. aws/us-east-1)

examples/resources/materialize_source_table_postgres/import.sh

@@ -1,5 +1,5 @@
-# Source tables can be imported using the source id:
-terraform import materialize_source_table_postgres.example_source_table_postgres <region>:<source_id>
+# Source tables can be imported using the source table id:
+terraform import materialize_source_table_postgres.example_source_table_postgres <region>:<source_table_id>
 
 # Source id and information be found in the `mz_catalog.mz_tables` table
 # The region is the region where the database is located (e.g. aws/us-east-1)