s3_sink_connector_02.json

{
    "connector.class": "io.confluent.connect.s3.S3SinkConnector",
    "tasks.max": 1,
    "topics": "pagila.query",
    "s3.region": "us-east-1",
    "s3.bucket.name": "your-s3-bucket",
    "s3.part.size": 5242880,
    "flush.size": 100,
    "rotate.schedule.interval.ms": 60000,
    "timezone": "UTC",
    "storage.class": "io.confluent.connect.s3.storage.S3Storage",
    "format.class": "io.confluent.connect.s3.format.parquet.ParquetFormat",
    "parquet.codec": "gzip",
    "partitioner.class": "io.confluent.connect.storage.partitioner.FieldPartitioner",
    "partition.field.name": "country",
    "schema.compatibility": "NONE",
    "transforms": "RenameField, insertStaticField1,insertStaticField2,insertStaticField3",
    "transforms.RenameField.type": "org.apache.kafka.connect.transforms.ReplaceField$Value",
    "transforms.RenameField.renames": "district:state_province",
    "transforms.insertStaticField1.type": "org.apache.kafka.connect.transforms.InsertField$Value",
    "transforms.insertStaticField1.static.field": "message_source",
    "transforms.insertStaticField1.static.value": "pagila",
    "transforms.insertStaticField2.type": "org.apache.kafka.connect.transforms.InsertField$Value",
    "transforms.insertStaticField2.static.field": "message_source_engine",
    "transforms.insertStaticField2.static.value": "postgresql",
    "transforms.insertStaticField3.type": "org.apache.kafka.connect.transforms.InsertField$Value",
    "transforms.insertStaticField3.static.field": "environment",
    "transforms.insertStaticField3.static.value": "development"
}