minor

vdesabou · Aug 1, 2023 · b0256a5 · b0256a5
1 parent edfc29a
commit b0256a5
Show file tree

Hide file tree

Showing 2 changed files with 30 additions and 30 deletions.
diff --git a/connect/connect-aws-s3-source/s3-source-backup-and-restore-with-assuming-iam-role.sh b/connect/connect-aws-s3-source/s3-source-backup-and-restore-with-assuming-iam-role.sh
@@ -105,20 +105,20 @@ rm -f s3_topic+0+0000000000.avro
 log "Creating Backup and Restore S3 Source connector with bucket name <$AWS_BUCKET_NAME>"
 playground connector create-or-update --connector s3-source << EOF
 {
-               "tasks.max": "1",
-               "connector.class": "io.confluent.connect.s3.source.S3SourceConnector",
-               "s3.region": "$AWS_REGION",
-               "s3.bucket.name": "$AWS_BUCKET_NAME",
-               "topics.dir": "$TAG",
-               "format.class": "io.confluent.connect.s3.format.avro.AvroFormat",
-               "confluent.license": "",
-               "confluent.topic.bootstrap.servers": "broker:9092",
-               "confluent.topic.replication.factor": "1",
-               "transforms": "AddPrefix",
-               "transforms.AddPrefix.type": "org.apache.kafka.connect.transforms.RegexRouter",
-               "transforms.AddPrefix.regex": ".*",
-               "transforms.AddPrefix.replacement": "copy_of_\$0"
-          }
+     "tasks.max": "1",
+     "connector.class": "io.confluent.connect.s3.source.S3SourceConnector",
+     "s3.region": "$AWS_REGION",
+     "s3.bucket.name": "$AWS_BUCKET_NAME",
+     "topics.dir": "$TAG",
+     "format.class": "io.confluent.connect.s3.format.avro.AvroFormat",
+     "confluent.license": "",
+     "confluent.topic.bootstrap.servers": "broker:9092",
+     "confluent.topic.replication.factor": "1",
+     "transforms": "AddPrefix",
+     "transforms.AddPrefix.type": "org.apache.kafka.connect.transforms.RegexRouter",
+     "transforms.AddPrefix.regex": ".*",
+     "transforms.AddPrefix.replacement": "copy_of_\$0"
+}
 EOF
 
 sleep 10

diff --git a/connect/connect-aws-s3-source/s3-source-backup-and-restore.sh b/connect/connect-aws-s3-source/s3-source-backup-and-restore.sh
@@ -119,22 +119,22 @@ rm -f s3_topic+0+0000000000.avro
 log "Creating Backup and Restore S3 Source connector with bucket name <$AWS_BUCKET_NAME>"
 playground connector create-or-update --connector s3-source << EOF
 {
-               "tasks.max": "1",
-               "connector.class": "io.confluent.connect.s3.source.S3SourceConnector",
-               "s3.region": "$AWS_REGION",
-               "s3.bucket.name": "$AWS_BUCKET_NAME",
-               "topics.dir": "$TAG",
-               "aws.access.key.id" : "$AWS_ACCESS_KEY_ID",
-               "aws.secret.access.key": "$AWS_SECRET_ACCESS_KEY",
-               "format.class": "io.confluent.connect.s3.format.avro.AvroFormat",
-               "confluent.license": "",
-               "confluent.topic.bootstrap.servers": "broker:9092",
-               "confluent.topic.replication.factor": "1",
-               "transforms": "AddPrefix",
-               "transforms.AddPrefix.type": "org.apache.kafka.connect.transforms.RegexRouter",
-               "transforms.AddPrefix.regex": ".*",
-               "transforms.AddPrefix.replacement": "copy_of_\$0"
-          }
+    "tasks.max": "1",
+    "connector.class": "io.confluent.connect.s3.source.S3SourceConnector",
+    "s3.region": "$AWS_REGION",
+    "s3.bucket.name": "$AWS_BUCKET_NAME",
+    "topics.dir": "$TAG",
+    "aws.access.key.id" : "$AWS_ACCESS_KEY_ID",
+    "aws.secret.access.key": "$AWS_SECRET_ACCESS_KEY",
+    "format.class": "io.confluent.connect.s3.format.avro.AvroFormat",
+    "confluent.license": "",
+    "confluent.topic.bootstrap.servers": "broker:9092",
+    "confluent.topic.replication.factor": "1",
+    "transforms": "AddPrefix",
+    "transforms.AddPrefix.type": "org.apache.kafka.connect.transforms.RegexRouter",
+    "transforms.AddPrefix.regex": ".*",
+    "transforms.AddPrefix.replacement": "copy_of_\$0"
+}
 EOF
 
 sleep 10