kafka-connect-client

kafka-connect-client copied to clipboard

ConnectorStatus.getConnector() should return type-safe object instead of map

1

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

0xERR0R

NewConnectorDefinition.config should be Map<String, Object>

2

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

MosheElisha

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

Crim

KafkaConnectClient not supporting stop operation

1

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

elene

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

derecknowayback

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]