Skip to content

Instantly share code, notes, and snippets.

@anand086

anand086/msk_connector_configuration_eu-central-1

Created September 4, 2022 08:22
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save anand086/3ae73eae01d47529c4541d1c71828ffc to your computer and use it in GitHub Desktop.
Save anand086/3ae73eae01d47529c4541d1c71828ffc to your computer and use it in GitHub Desktop.
Download ZIP
Raw
msk_connector_configuration_eu-central-1
connector.class=io.lenses.streamreactor.connect.aws.s3.sink.S3SinkConnector
tasks.max=2
topics=transaction_events
connect.s3.vhost.bucket=true
schema.enable=false
key.converter.schemas.enable=false
connect.s3.kcql=INSERT INTO msk-lensesio-plugin:MSKCluster SELECT * FROM transaction_events STOREAS `JSON` WITH_FLUSH_INTERVAL = 300
aws.region=eu-central-1
aws.custom.endpoint=https://s3.eu-central-1.amazonaws.com/
value.converter.schemas.enable=false
connect.s3.aws.region=eu-central-1
value.converter=org.apache.kafka.connect.json.JsonConverter
errors.log.enable=true
key.converter=org.apache.kafka.connect.json.JsonConverter
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment