Skip to content

Instantly share code, notes, and snippets.

Show Gist options
  • Select an option

  • Save marcellobarile/2ce1c4781a0c3240883bca0912433443 to your computer and use it in GitHub Desktop.

Select an option

Save marcellobarile/2ce1c4781a0c3240883bca0912433443 to your computer and use it in GitHub Desktop.
test 2
[
{
"$schema": "https://unpkg.com/@camunda/zeebe-element-templates-json-schema/resources/schema.json",
"name": "Kafka producer connector",
"id": "io.camunda.connectors.KAFKA.v1",
"version": 1,
"description": "Produce Kafka message",
"documentationRef": "https://docs.camunda.io/docs/components/connectors/out-of-the-box-connectors/kafka/",
"category": {
"id": "connectors",
"name": "Connectors"
},
"appliesTo": [
"bpmn:Task"
],
"elementType": {
"value": "bpmn:ServiceTask"
},
"groups": [
{
"id": "authentication",
"label": "Authentication"
},
{
"id": "kafka",
"label": "Kafka"
},
{
"id": "message",
"label": "Message"
},
{
"id": "output",
"label": "Response mapping"
},
{
"id": "errors",
"label": "Error handling"
}
],
"properties": [
{
"type": "Hidden",
"value": "io.camunda:connector-kafka:1",
"binding": {
"type": "zeebe:taskDefinition:type"
}
},
{
"label": "Username",
"description": "Provide the username (must have permissions to produce message to the topic)",
"group": "authentication",
"type": "String",
"optional": true,
"binding": {
"type": "zeebe:input",
"name": "authentication.username"
}
},
{
"label": "Password",
"description": "Provide a password for the user",
"group": "authentication",
"type": "String",
"optional": true,
"binding": {
"type": "zeebe:input",
"name": "authentication.password"
}
},
{
"label": "Bootstrap servers",
"description": "Provide bootstrap server(s), comma-delimited if there are multiple",
"group": "kafka",
"type": "String",
"feel": "optional",
"binding": {
"type": "zeebe:input",
"name": "topic.bootstrapServers"
},
"constraints": {
"notEmpty": true
}
},
{
"label": "Topic",
"description": "Provide topic name",
"group": "kafka",
"type": "String",
"feel": "optional",
"binding": {
"type": "zeebe:input",
"name": "topic.topicName"
},
"constraints": {
"notEmpty": true
}
},
{
"label": "Additional properties",
"description": "Provide additional Kafka producer properties in JSON",
"group": "kafka",
"type": "String",
"optional": true,
"feel": "required",
"binding": {
"type": "zeebe:input",
"name": "additionalProperties"
}
},
{
"label": "Key",
"description": "Provide message key",
"group": "message",
"type": "String",
"feel": "optional",
"binding": {
"type": "zeebe:input",
"name": "message.key"
},
"constraints": {
"notEmpty": true
}
},
{
"label": "Value",
"description": "Provide message value",
"group": "message",
"type": "String",
"feel": "optional",
"binding": {
"type": "zeebe:input",
"name": "message.value"
},
"constraints": {
"notEmpty": true
}
},
{
"label": "Result variable",
"description": "Name of variable to store the response in. Details in the <a href=\"https://docs.camunda.io/docs/components/connectors/use-connectors/#result-variable\" target=\"_blank\">documentation</a>",
"group": "output",
"type": "String",
"binding": {
"type": "zeebe:taskHeader",
"key": "resultVariable"
}
},
{
"label": "Result expression",
"description": "Expression to map the response into process variables. Details in the <a href=\"https://docs.camunda.io/docs/components/connectors/use-connectors/#result-expression\" target=\"_blank\">documentation</a>",
"group": "output",
"type": "Text",
"feel": "required",
"binding": {
"type": "zeebe:taskHeader",
"key": "resultExpression"
}
},
{
"label": "Error expression",
"description": "Expression to handle errors. Details in the <a href=\"https://docs.camunda.io/docs/components/connectors/use-connectors/#bpmn-errors\" target=\"_blank\">documentation</a>",
"group": "errors",
"type": "Text",
"feel": "required",
"binding": {
"type": "zeebe:taskHeader",
"key": "errorExpression"
}
}
],
"icon": {
"contents": "data:image/svg+xml;utf8,%3Csvg width='18' height='18' viewBox='0 0 256 416' xmlns='http://www.w3.org/2000/svg' preserveAspectRatio='xMidYMid'%3E%3Cpath d='M201.816 230.216c-16.186 0-30.697 7.171-40.634 18.461l-25.463-18.026c2.703-7.442 4.255-15.433 4.255-23.797 0-8.219-1.498-16.076-4.112-23.408l25.406-17.835c9.936 11.233 24.409 18.365 40.548 18.365 29.875 0 54.184-24.305 54.184-54.184 0-29.879-24.309-54.184-54.184-54.184-29.875 0-54.184 24.305-54.184 54.184 0 5.348.808 10.505 2.258 15.389l-25.423 17.844c-10.62-13.175-25.911-22.374-43.333-25.182v-30.64c24.544-5.155 43.037-26.962 43.037-53.019C124.171 24.305 99.862 0 69.987 0 40.112 0 15.803 24.305 15.803 54.184c0 25.708 18.014 47.246 42.067 52.769v31.038C25.044 143.753 0 172.401 0 206.854c0 34.621 25.292 63.374 58.355 68.94v32.774c-24.299 5.341-42.552 27.011-42.552 52.894 0 29.879 24.309 54.184 54.184 54.184 29.875 0 54.184-24.305 54.184-54.184 0-25.883-18.253-47.553-42.552-52.894v-32.775a69.965 69.965 0 0 0 42.6-24.776l25.633 18.143c-1.423 4.84-2.22 9.946-2.22 15.24 0 29.879 24.309 54.184 54.184 54.184 29.875 0 54.184-24.305 54.184-54.184 0-29.879-24.309-54.184-54.184-54.184zm0-126.695c14.487 0 26.27 11.788 26.27 26.271s-11.783 26.27-26.27 26.27-26.27-11.787-26.27-26.27c0-14.483 11.783-26.271 26.27-26.271zm-158.1-49.337c0-14.483 11.784-26.27 26.271-26.27s26.27 11.787 26.27 26.27c0 14.483-11.783 26.27-26.27 26.27s-26.271-11.787-26.271-26.27zm52.541 307.278c0 14.483-11.783 26.27-26.27 26.27s-26.271-11.787-26.271-26.27c0-14.483 11.784-26.27 26.271-26.27s26.27 11.787 26.27 26.27zm-26.272-117.97c-20.205 0-36.642-16.434-36.642-36.638 0-20.205 16.437-36.642 36.642-36.642 20.204 0 36.641 16.437 36.641 36.642 0 20.204-16.437 36.638-36.641 36.638zm131.831 67.179c-14.487 0-26.27-11.788-26.27-26.271s11.783-26.27 26.27-26.27 26.27 11.787 26.27 26.27c0 14.483-11.783 26.271-26.27 26.271z' style='fill:%23231f20'/%3E%3C/svg%3E"
}
}
]
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment