Updated connector sample configs.

Author: salmany

managedkafka/managedkafka_create_connector_cloud_storage_sink/main.tf

@@ -80,7 +80,7 @@ resource "google_managed_kafka_connector" "example-cloud-storage-sink-connector"
 
   configs = {
     "connector.class"                = "io.aiven.kafka.connect.gcs.GcsSinkConnector"
-    "tasks.max"                      = "1"
+    "tasks.max"                      = "3"
     "topics"                         = "GMK_TOPIC_ID"
     "gcs.bucket.name"                = "GCS_BUCKET_NAME"
     "gcs.credentials.default"        = "true"

managedkafka/managedkafka_create_connector_mirrormaker_source/main.tf

@@ -81,20 +81,12 @@ resource "google_managed_kafka_connector" "default" {
   configs = {
     "connector.class"                                  = "org.apache.kafka.connect.mirror.MirrorSourceConnector"
     "name"                                             = "MM2_CONNECTOR_ID"
+    "tasks.max"                                        = "3"
     "source.cluster.alias"                             = "source"
     "target.cluster.alias"                             = "target"
     "topics"                                           = "GMK_TOPIC_NAME"
     "source.cluster.bootstrap.servers"                 = "GMK_SOURCE_CLUSTER_DNS"
     "target.cluster.bootstrap.servers"                 = "GMK_TARGET_CLUSTER_DNS"
-    "offset-syncs.topic.replication.factor"            = "1"
-    "source.cluster.security.protocol"                 = "SASL_SSL"
-    "source.cluster.sasl.mechanism"                    = "OAUTHBEARER"
-    "source.cluster.sasl.login.callback.handler.class" = "com.google.cloud.hosted.kafka.auth.GcpLoginCallbackHandler"
-    "source.cluster.sasl.jaas.config"                  = "org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule required;"
-    "target.cluster.security.protocol"                 = "SASL_SSL"
-    "target.cluster.sasl.mechanism"                    = "OAUTHBEARER"
-    "target.cluster.sasl.login.callback.handler.class" = "com.google.cloud.hosted.kafka.auth.GcpLoginCallbackHandler"
-    "target.cluster.sasl.jaas.config"                  = "org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule required;"
   }
 
   provider = google-beta

managedkafka/managedkafka_create_connector_pubsub_sink/main.tf

@@ -81,7 +81,7 @@ resource "google_managed_kafka_connector" "example-pubsub-sink-connector" {
   configs = {
     "connector.class" = "com.google.pubsub.kafka.sink.CloudPubSubSinkConnector"
     "name"            = "my-pubsub-sink-connector"
-    "tasks.max"       = "1"
+    "tasks.max"       = "3"
     "topics"          = "TOPIC_NAME"
     "cps.topic"       = "CPS_TOPIC_NAME"
     "cps.project"     = "CPS_PROJECT_NAME"

managedkafka/managedkafka_create_connector_pubsub_source/main.tf

@@ -81,7 +81,7 @@ resource "google_managed_kafka_connector" "example-pubsub-source-connector" {
   configs = {
     "connector.class"  = "com.google.pubsub.kafka.source.CloudPubSubSourceConnector"
     "name"             = "my-pubsub-source-connector"
-    "tasks.max"        = "1"
+    "tasks.max"        = "3"
     "kafka.topic"      = "GMK_TOPIC_ID"
     "cps.subscription" = "CPS_SUBSCRIPTION_ID"
     "cps.project"      = "GCP_PROJECT_ID"