kafka-connect-zeebe

kafka-connect-zeebe copied to clipboard

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):...

dependabot[bot]

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...

dependabot[bot]

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...

dependabot[bot]

Make source variables filtering more powerful

1

aragornfbm

Make source variables filtering more powerful

5

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...

aragornfbm

ClassCastException: class io.netty.channel.epoll.EpollSocketChannel

2

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....

vdesabou

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...

umesh-kushwaha

Feature request: Backoff the retry when gateway reports RESOURCE_EXHAUSTED

7

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.

jwulf

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...

mkoziel2000

NullPointerException io.zeebe.kafka.connect.source.ZeebeSourceTask.commit

1

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...

lrealdi