Kafka Receive Task Connector

Consume Kafka messages

inbound-intermediate

Required inputs

Key	Label	Type
`authenticationType`	Authentication type	string
`topic.bootstrapServers`	Bootstrap servers	string
`topic.topicName`	Topic	string
`autoOffsetReset`	Auto offset reset	string
`schemaStrategy.avro.schema`	Schema	FEEL expression
`schemaStrategy.schemaRegistryUrl`	Schema registry URL	string
`correlationKeyProcess`	Correlation key (process)	FEEL expression
`correlationKeyPayload`	Correlation key (payload)	FEEL expression
`deduplicationId`	Deduplication ID	string

Optional inputs

Key	Label	Type
`authentication.username`	Username	string
`authentication.password`	Password	secret
`groupId`	Consumer group ID	string
`additionalProperties`	Additional properties	FEEL expression
`offsets`	Offsets	FEEL expression
`schemaStrategy.type`	Schema strategy	string
`schemaStrategy.schemaType`	Schema type	string
`activationCondition`	Activation condition	FEEL expression
`consumeUnmatchedEvents`	Consume unmatched events	string
`messageIdExpression`	Message ID expression	FEEL expression
`messageTtl`	Message TTL	FEEL expression
`deduplicationModeManualFlag`	Manual mode	string
`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.KafkaReceive.v1", { "authenticationType": "credentials", "topic.bootstrapServers": "...", "topic.topicName": "...", "autoOffsetReset": "none", "schemaStrategy.avro.schema": "= ...", "schemaStrategy.schemaRegistryUrl": "...", "correlationKeyProcess": "= ...", "correlationKeyPayload": "= ...", "deduplicationId": "...", "authentication.username": "...", "authentication.password": "<your password>", })