kafka-connect-client
kafka-connect-client copied to clipboard
SourceLabOrg
A kafka-connect REST api client for java
Current implementation of `ConnectorStatus.getConnector()` returns a Map with "state" and "worker_id". It would be handy to get Object with state as enum and worker_id as String. See also TaskStatus
Hi, I believe NewConnectorDefinition.config should be `Map` instead of `Map`. This will better support non-string configuration such as `tasks.max` and `errors.deadletterqueue.topic.replication.factor` which are numbers. Perhaps for backward-compatibility there is a...
 ### Snyk has created this PR to fix 1 vulnerabilities in the maven dependencies of this project. #### Snyk changed the following file(s): - `pom.xml` #### Vulnerabilities that will...
Hi, KafkaConnectClient doesn't implement stop endpoint from [KafkaConnect API](https://docs.confluent.io/platform/current/connect/references/restapi.html#put--connectors-(string-name)-stop). Is it intentional or it just was not implemented? It should be straightforward to implement: - Create a new `PutConnectorStop` class...
I've noticed that there are many classes, such as `ConnectorDefinition`, which bear a strong resemblance to the `ConnectorInfo` class found in the Kafka connect-runtime package. This seems to be a...
Bumps org.eclipse.jetty:jetty-server from 9.4.54.v20240208 to 9.4.55.v20240627. [](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a...
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot] avatar"){kind=avatar}
Using this library with latest Quarkus (3.28.5 at the moment of writing) fails with `Caused by: java.lang.NoSuchFieldError: Class com.fasterxml.jackson.databind.PropertyNamingStrategy does not have member field 'com.fasterxml.jackson.databind.PropertyNamingStrategy SNAKE_CASE'` due to usage of...
 ### Snyk has created this PR to fix 1 vulnerabilities in the maven dependencies of this project. #### Snyk changed the following file(s): - `pom.xml` #### Vulnerabilities that will...
Ran a test with an invalid consumer override config: ```java @Test public void testValidateConnectorPluginConfig() { ConnectorPluginConfigValidationResults results = kafkaConnectClient.validateConnectorPluginConfig( ConnectorPluginConfigDefinition.newBuilder() .withName("JdbcSinkConnector") .withConfig("connector.class", "io.confluent.connect.jdbc.JdbcSinkConnector") .withConfig("tasks.max", "1") .withConfig("connection.url", "jdbc:postgresql://postgres:5432/postgres?user=postgres&password=pwd&ssl=false") .withConfig("mode", "incrementing") .withConfig("topics",...
