kafka-connect-zeebe
kafka-connect-zeebe copied to clipboard
Kafka Connect for Zeebe.io
Bumps `version.zeebe` from 8.0.5 to 8.0.6. Updates `zeebe-bom` from 8.0.5 to 8.0.6 Commits eab2ac8 [maven-release-plugin] prepare release 8.0.6 65b180c build(project): update go embedded version data f687fae merge: #10210 886ccb1 test(raft):...
Bumps [maven-checkstyle-plugin](https://github.com/apache/maven-checkstyle-plugin) from 3.1.2 to 3.2.0. Commits 1aaf7cb [maven-release-plugin] prepare release maven-checkstyle-plugin-3.2.0 627fa4f [MCHECKSTYLE-417] Upgrade Maven Reporting API to 3.1.1/Maven Reporting Impl t... cbf3751 [MCHECKSTYLE-418] Deprecate RSS feature and disable...
Bumps [slf4j-api](https://github.com/qos-ch/slf4j) from 1.7.36 to 2.0.0. Commits 0614d46 prepare release 2.0.0 b1afcd0 javadoc edits 20cd3ad start work on 2.0.0-SNAPSHOT aeebb61 prepare release 2.0.0-beta1 1068cd0 javadoc changes 4e4e56a add CheckReturnValue annotation...
According to the documentation, the "_job.variables_" property should contain the name of a custom header that is defined in the source task and that contains a comma-separated list of variables...
Using Confluent Platform(CP) 7.0.1, I get the following error with the connector (tested with 0.32.0 and 0.40.0): ``` [2022-06-23 07:44:54,564] ERROR [zeebe-sink|task-2] WorkerSourceTask{id=zeebe-sink-2} Task threw an uncaught and unrecoverable exception....
Currently, SINK connector consume messages in batch but publishing message to zeebe in multiple thread. https://github.com/camunda-community-hub/kafka-connect-zeebe/blob/master/src/main/java/io/zeebe/kafka/connect/sink/ZeebeSinkTask.java#L102 For example, it consume 10 records in batch then it will fire 10 thread...
When the broker signals backpressure, the Kafka sink responds with an immediate retry. See: https://github.com/camunda-community-hub/kafka-connect-zeebe/blob/master/src/main/java/io/zeebe/kafka/connect/sink/ZeebeSinkFuture.java#L76 It should backoff the retry to give the broker a chance to recover.
It would be great if we had the ability to pull kafka headers out as variables on the sink side and then pack the headers from variables on the source...
Hi I have this issue with kafka-connect-zeebe-0.32.1-SNAPSHOT.jar This is my docker-compose ``` version: "3" services: zeebe: image: camunda/zeebe:${CAMUNDA_CLOUD_VERSION:-1.2.4} container_name: zeebe environment: - ZEEBE_BROKER_EXPORTERS_ELASTICSEARCH_CLASSNAME=io.camunda.zeebe.exporter.ElasticsearchExporter - ZEEBE_BROKER_EXPORTERS_ELASTICSEARCH_ARGS_URL=http://elasticsearch:9200 - ZEEBE_BROKER_EXPORTERS_ELASTICSEARCH_ARGS_BULK_SIZE=1 ports: - 26500:26500...