kafka-connect-http
kafka-connect-http copied to clipboard
castorm
Kafka Connect connector that enables Change Data Capture from JSON/HTTP APIs into Kafka.
**Is your feature request related to a problem? Please describe.** Recently I have been working on a project that requires the HTTP source connector. But the API returns only a...
I am working with an Odata API interface which presents timestamp values such as lastModified in a format similar to `//Date(1530144000000+0530)/. Would it be possible to get such date formats...
Hello, I am looking to: 1. Use my "source" topic to feed a json payload into the body of the HTTP request. 2. Receive and store the response in an...
Bumps [mockito-junit-jupiter](https://github.com/mockito/mockito) from 4.3.1 to 4.8.1. Release notes Sourced from mockito-junit-jupiter's releases. v4.8.1 Changelog generated by Shipkit Changelog Gradle Plugin 4.8.1 2022-10-17 - 6 commit(s) by andrepaschoal, dependabot[bot] Possible fix...
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot] avatar"){kind=avatar}
Bumps [jackson-databind](https://github.com/FasterXML/jackson) from 2.13.1 to 2.13.4.2. Commits See full diff in compare view [](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...
The following vulnerabilities are identified with the connector. CVE-2020-36518 CVE-2020-29582 CVE-2022-24329 Could you please verify it for false positive?
Bumps [wiremock-jre8](https://github.com/wiremock/wiremock) from 2.32.0 to 2.34.0. Release notes Sourced from wiremock-jre8's releases. 2.34.0 This will be the final 2.x.x release and also the last to support Java 8. Fixes Fixed...
**Is your feature request related to a problem? Please describe.** Now it only support Basic authentication, does not support Bearer Token. **Describe the solution you'd like** Add the BearerHttpAuthenticator and...
The data payload coming from the HTTP Endpoint does not have a "root" level key. The JSON array is flat. [{key:value, key:value, key:value} , {key:value, key:value, key:value} ] Error thrown...
**Describe the bug** When the `http.timer.interval.millis` value is lower than the `offset.flush.interval.ms` kafka connect worker setting, the records in topic are duplicated every `http.timer.interval.millis` until offset is commited. **To Reproduce**...
