Kafka Boundary Event Connector

Consume Kafka messages

inbound-boundary

Required inputs

Key	Label	Type
`topic.bootstrapServers`	Bootstrap servers	FEEL expression
`topic.topicName`	Topic	FEEL expression
	Correlation key (process)	FEEL expression
`correlationKeyExpression`	Correlation key (payload)	FEEL expression

Optional inputs

Key	Label	Type
`authenticationType`	Authentication type	string
`authentication.username`	Username	FEEL expression
`authentication.password`	Password	secret
`groupId`	Consumer Group ID	FEEL expression
`additionalProperties`	Additional properties	FEEL expression
`offsets`	Offsets	FEEL expression
`autoOffsetReset`	Auto offset reset	string
`activationCondition`	Activation condition	FEEL expression
`resultVariable`	Result variable	string
`resultExpression`	Result expression	FEEL expression

Apply this connector with @bpmnkit/connectors

import { applyConnectorTemplate } from "@bpmnkit/connectors" const result = applyConnectorTemplate("io.camunda.connectors.inbound.KafkaBoundary.v1", { "topic.bootstrapServers": "= ...", "topic.topicName": "= ...", "": "= ...", "correlationKeyExpression": "= ...", "authenticationType": "credentials", "authentication.username": "= ...", })