Kafka producer connector
Produce Kafka message
Required inputs
| Key | Label | Type |
|---|---|---|
topic.bootstrapServers | Bootstrap servers | FEEL expression |
topic.topicName | Topic | FEEL expression |
message.key | Key | FEEL expression |
message.value | Value | FEEL expression |
Optional inputs
| Key | Label | Type |
|---|---|---|
authentication.username | Username | string |
authentication.password | Password | secret |
additionalProperties | Additional properties | FEEL expression |
resultVariable | Result variable | string |
resultExpression | Result expression | FEEL expression |
errorExpression | Error expression | FEEL expression |
Apply this connector with @bpmnkit/connectors
import { applyConnectorTemplate } from "@bpmnkit/connectors"
const result = applyConnectorTemplate("io.camunda.connectors.KAFKA.v1", {
"topic.bootstrapServers": "= ...",
"topic.topicName": "= ...",
"message.key": "= ...",
"message.value": "= ...",
"authentication.username": "...",
"authentication.password": "<your password>",
})