Alistair Yan

Kafka Connect | Inconsistent behaviour with REST API in Distributed Mode

2

When running the following request against the kafka connect cluster in distributed mode (2 worker pods) in k8s, the following can be observed: ``` curl http://kafka-connect:8083/connectors/test -X DELETE {"error_code":500,"message":"Error trying...

Make use of RetriableException

1

In order to make use of the kafka connector retrying mechanism, would it be possible to throw a [RetriableException](https://kafka.apache.org/0100/javadoc/index.html?org/apache/kafka/common/errors/RetriableException.html) instead of a ConnectException [here](https://github.com/aiven/http-connector-for-apache-kafka/blob/main/src/main/java/io/aiven/kafka/connect/http/sender/HttpSender.java#L96) and [here](https://github.com/aiven/http-connector-for-apache-kafka/blob/main/src/main/java/io/aiven/kafka/connect/http/sender/HttpSender.java#L100). This would enable us...

**Describe the bug** A persistent query stopped working completely. Seemingly during a maintenance window, and is in an irrecoverable state. I have not been able to reproduce the error **To...