Problemas:
JSONs:
{
"name": "flow-retail-source",
"config": {
"zeebe.client.job.worker": "kafka-connector",
"zeebe.client.job.pollinterval": "2000",
"name": "flow-retail-source",
"connector.class": "io.zeebe.kafka.connect.ZeebeSourceConnector",
"tasks.max": "1",
"key.converter": "org.apache.kafka.connect.storage.StringConverter",
"value.converter": "org.apache.kafka.connect.storage.StringConverter",
"zeebe.client.broker.contactPoint": "cluster-1-zeebe-gateway.zeebe.svc.cluster.local:26500",
"zeebe.client.requestTimeout": "10000",
"zeebe.client.security.plaintext": "true",
"zeebe.client.worker.name": "kafka-connector",
"zeebe.client.worker.maxJobsActive": "1000",
"zeebe.client.job.timeout": "5000",
"job.types": "sendMessage",
"job.header.topics": "kafka-topic"
}
}{
"name": "flow-retail-sink",
"config": {
"connector.class": "io.zeebe.kafka.connect.ZeebeSinkConnector",
"tasks.max": "1",
"key.converter": "org.apache.kafka.connect.storage.StringConverter",
"value.converter": "org.apache.kafka.connect.storage.StringConverter",
"topics": "payment-confirm",
"errors.tolerance": "all",
"errors.deadletterqueue.topic.name":"deadletterqueue",
"errors.deadletterqueue.topic.replication.factor": 1,
"zeebe.client.broker.contactPoint": "cluster-1-zeebe-gateway.zeebe.svc.cluster.local:26500",
"zeebe.client.requestTimeout": "10000",
"zeebe.client.security.plaintext": true,
"message.path.messageName": "$.eventType",
"message.path.correlationKey": "$.orderId",
"message.path.variables": "$.['amount', 'orderId']"
}
}