Skip to content

Commit 9599c11

Browse files
salmanysalmany
committed
Fixed formatting.
1 parent ad846d7 commit 9599c11

File tree

5 files changed

+52
-52
lines changed
  • managedkafka
    • managedkafka_create_connector_bigquery_sink
    • managedkafka_create_connector_cloud_storage_sink
    • managedkafka_create_connector_mirrormaker
    • managedkafka_create_connector_pubsub_sink
    • managedkafka_create_connector_pubsub_source

5 files changed

+52
-52
lines changed

‎managedkafka/managedkafka_create_connector_bigquery_sink/main.tf‎

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -58,21 +58,21 @@ resource "google_managed_kafka_connect_cluster" "default" {
5858

5959
# [START managedkafkaconnect_create_connector_bigquery_sink]
6060
resource "google_managed_kafka_connector" "example-bigquery-sink-connector" {
61-
project = data.google_project.default.project_id
61+
project = data.google_project.default.project_id
6262
connector_id = "my-bigquery-sink-connector"
6363
connect_cluster = google_managed_kafka_connect_cluster.default.connect_cluster_id
6464
location = "us-central1"
6565

6666
configs = {
67-
"name" = "my-bigquery-sink-connector"
68-
"project" = "GCP_PROJECT_ID"
69-
"topics" = "GMK_TOPIC_ID"
70-
"tasks.max" = "3"
71-
"connector.class" = "com.wepay.kafka.connect.bigquery.BigQuerySinkConnector"
72-
"key.converter" = "org.apache.kafka.connect.storage.StringConverter"
73-
"value.converter" = "org.apache.kafka.connect.json.JsonConverter"
74-
"value.converter.schemas.enable"= "false"
75-
"defaultDataset" = "BQ_DATASET_ID"
67+
"name" = "my-bigquery-sink-connector"
68+
"project" = "GCP_PROJECT_ID"
69+
"topics" = "GMK_TOPIC_ID"
70+
"tasks.max" = "3"
71+
"connector.class" = "com.wepay.kafka.connect.bigquery.BigQuerySinkConnector"
72+
"key.converter" = "org.apache.kafka.connect.storage.StringConverter"
73+
"value.converter" = "org.apache.kafka.connect.json.JsonConverter"
74+
"value.converter.schemas.enable" = "false"
75+
"defaultDataset" = "BQ_DATASET_ID"
7676
}
7777

7878
provider = google-beta

‎managedkafka/managedkafka_create_connector_cloud_storage_sink/main.tf‎

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -58,22 +58,22 @@ resource "google_managed_kafka_connect_cluster" "default" {
5858

5959
# [START managedkafkaconnect_create_connector_cloud_storage_sink]
6060
resource "google_managed_kafka_connector" "example-cloud-storage-sink-connector" {
61-
project = data.google_project.default.project_id
61+
project = data.google_project.default.project_id
6262
connector_id = "my-gcs-sink-connector"
6363
connect_cluster = google_managed_kafka_connect_cluster.default.connect_cluster_id
6464
location = "us-central1"
6565

6666
configs = {
67-
"connector.class" = "io.aiven.kafka.connect.gcs.GcsSinkConnector"
68-
"tasks.max" = "1"
69-
"topics" = "GMK_TOPIC_ID"
70-
"gcs.bucket.name" = "GCS_BUCKET_NAME"
71-
"gcs.credentials.default" = "true"
72-
"format.output.type" = "json"
73-
"name" = "my-gcs-sink-connector"
74-
"value.converter" = "org.apache.kafka.connect.json.JsonConverter"
75-
"value.converter.schemas.enable"= "false"
76-
"key.converter" = "org.apache.kafka.connect.storage.StringConverter"
67+
"connector.class" = "io.aiven.kafka.connect.gcs.GcsSinkConnector"
68+
"tasks.max" = "1"
69+
"topics" = "GMK_TOPIC_ID"
70+
"gcs.bucket.name" = "GCS_BUCKET_NAME"
71+
"gcs.credentials.default" = "true"
72+
"format.output.type" = "json"
73+
"name" = "my-gcs-sink-connector"
74+
"value.converter" = "org.apache.kafka.connect.json.JsonConverter"
75+
"value.converter.schemas.enable" = "false"
76+
"key.converter" = "org.apache.kafka.connect.storage.StringConverter"
7777
}
7878
provider = google-beta
7979
}

‎managedkafka/managedkafka_create_connector_mirrormaker/main.tf‎

Lines changed: 14 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -64,22 +64,22 @@ resource "google_managed_kafka_connector" "default" {
6464
location = "us-central1"
6565

6666
configs = {
67-
"connector.class" = "org.apache.kafka.connect.mirror.MirrorSourceConnector"
68-
"name" = "MM2_CONNECTOR_ID"
69-
"source.cluster.alias" = "source"
70-
"target.cluster.alias" = "target"
71-
"topics" = "GMK_TOPIC_NAME"
72-
"source.cluster.bootstrap.servers" = "GMK_SOURCE_CLUSTER_DNS"
73-
"target.cluster.bootstrap.servers" = "GMK_TARGET_CLUSTER_DNS"
74-
"offset-syncs.topic.replication.factor" = "1"
75-
"source.cluster.security.protocol" = "SASL_SSL"
76-
"source.cluster.sasl.mechanism" = "OAUTHBEARER"
67+
"connector.class" = "org.apache.kafka.connect.mirror.MirrorSourceConnector"
68+
"name" = "MM2_CONNECTOR_ID"
69+
"source.cluster.alias" = "source"
70+
"target.cluster.alias" = "target"
71+
"topics" = "GMK_TOPIC_NAME"
72+
"source.cluster.bootstrap.servers" = "GMK_SOURCE_CLUSTER_DNS"
73+
"target.cluster.bootstrap.servers" = "GMK_TARGET_CLUSTER_DNS"
74+
"offset-syncs.topic.replication.factor" = "1"
75+
"source.cluster.security.protocol" = "SASL_SSL"
76+
"source.cluster.sasl.mechanism" = "OAUTHBEARER"
7777
"source.cluster.sasl.login.callback.handler.class" = "com.google.cloud.hosted.kafka.auth.GcpLoginCallbackHandler"
78-
"source.cluster.sasl.jaas.config" = "org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule required;"
79-
"target.cluster.security.protocol" = "SASL_SSL"
80-
"target.cluster.sasl.mechanism" = "OAUTHBEARER"
78+
"source.cluster.sasl.jaas.config" = "org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule required;"
79+
"target.cluster.security.protocol" = "SASL_SSL"
80+
"target.cluster.sasl.mechanism" = "OAUTHBEARER"
8181
"target.cluster.sasl.login.callback.handler.class" = "com.google.cloud.hosted.kafka.auth.GcpLoginCallbackHandler"
82-
"target.cluster.sasl.jaas.config" = "org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule required;"
82+
"target.cluster.sasl.jaas.config" = "org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule required;"
8383
}
8484

8585
provider = google-beta

‎managedkafka/managedkafka_create_connector_pubsub_sink/main.tf‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -59,22 +59,22 @@ resource "google_managed_kafka_connect_cluster" "default" {
5959

6060
# [START managedkafkaconnect_create_connector_pubsub_sink]
6161
resource "google_managed_kafka_connector" "example-pubsub-sink-connector" {
62-
project = data.google_project.default.project_id
62+
project = data.google_project.default.project_id
6363
connector_id = "my-pubsub-sink-connector"
6464
connect_cluster = google_managed_kafka_connect_cluster.default.connect_cluster_id
6565
location = "us-central1"
6666

6767
configs = {
6868
"connector.class" = "com.google.pubsub.kafka.sink.CloudPubSubSinkConnector"
69-
"name" = "my-pubsub-sink-connector"
70-
"tasks.max" = "1"
71-
"topics" = "TOPIC_NAME"
72-
"cps.topic" = "CPS_TOPIC_NAME"
73-
"cps.project" = "CPS_PROJECT_NAME"
69+
"name" = "my-pubsub-sink-connector"
70+
"tasks.max" = "1"
71+
"topics" = "TOPIC_NAME"
72+
"cps.topic" = "CPS_TOPIC_NAME"
73+
"cps.project" = "CPS_PROJECT_NAME"
7474
"value.converter" = "org.apache.kafka.connect.storage.StringConverter"
75-
"key.converter" = "org.apache.kafka.connect.storage.StringConverter"
75+
"key.converter" = "org.apache.kafka.connect.storage.StringConverter"
7676
}
77-
77+
7878
provider = google-beta
7979
}
8080
# [END managedkafkaconnect_create_connector_pubsub_sink]

‎managedkafka/managedkafka_create_connector_pubsub_source/main.tf‎

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -59,22 +59,22 @@ resource "google_managed_kafka_connect_cluster" "default" {
5959

6060
# [START managedkafkaconnect_create_connector_pubsub_source]
6161
resource "google_managed_kafka_connector" "example-pubsub-source-connector" {
62-
project = data.google_project.default.project_id
62+
project = data.google_project.default.project_id
6363
connector_id = "my-pubsub-source-connector"
6464
connect_cluster = google_managed_kafka_connect_cluster.default.connect_cluster_id
6565
location = "us-central1"
6666

6767
configs = {
68-
"connector.class" = "com.google.pubsub.kafka.source.CloudPubSubSourceConnector"
69-
"name" = "my-pubsub-source-connector"
70-
"tasks.max" = "1"
71-
"kafka.topic" = "GMK_TOPIC_ID"
68+
"connector.class" = "com.google.pubsub.kafka.source.CloudPubSubSourceConnector"
69+
"name" = "my-pubsub-source-connector"
70+
"tasks.max" = "1"
71+
"kafka.topic" = "GMK_TOPIC_ID"
7272
"cps.subscription" = "CPS_SUBSCRIPTION_ID"
73-
"cps.project" = "GCP_PROJECT_ID"
74-
"value.converter" = "org.apache.kafka.connect.converters.ByteArrayConverter"
75-
"key.converter" = "org.apache.kafka.connect.storage.StringConverter"
73+
"cps.project" = "GCP_PROJECT_ID"
74+
"value.converter" = "org.apache.kafka.connect.converters.ByteArrayConverter"
75+
"key.converter" = "org.apache.kafka.connect.storage.StringConverter"
7676
}
77-
77+
7878
provider = google-beta
7979
}
8080
# [END managedkafkaconnect_create_connector_pubsub_source]

0 commit comments

Comments
 (0)