Configure the connector
The reference configuration for the connector is available here. .
Here is a sample configuration for the connector:
name=kafka2ems connector.class=com.celonis.kafka.connect.ems.sink.EmsSinkConnector tasks.max=1 key.converter=org.apache.kafka.connect.storage.StringConverter value.converter=org.apache.kafka.connect.json.JsonConverter topics=payments connect.ems.endpoint=https://***.***.celonis.cloud/continuous-batch-processing/api/v1/***/items connect.ems.target.table=payments connect.ems.connection.id=**** connect.ems.commit.size.bytes=10000000 connect.ems.commit.records=100000 connect.ems.commit.interval.ms=30000 connect.ems.tmp.dir=/tmp/ems connect.ems.authorization.key="AppKey ***" connect.ems.error.policy=RETRY connect.ems.max.retries=20 connect.ems.retry.interval=60000 connect.ems.parquet.write.flush.records=1000 connect.ems.debug.keep.parquet.files=false
Examples here.