-
Home
-
Kafka Connectors
Changelog
Version 1.5.1
- Fix recommender for the
behavior.on.error
configuration property
Version 1.5.0
- Add a positive validator for batch max size
- Add support to filter private and local ips
- CCDB-3991: Do not log request payload
- Update parent to 0.7.1 to use guava 30.1 to address CVE-2020-8908
Version 1.4.0
- CCDB-3991: Do not log request payload
- CC-14842: Update guava to address CVE-2020-8908
- CC-14264: Performance improvement: report records asynchronously
- CC-14618: Avoid Authorization Header logging
- Removed the ssl.enabled property, SSL is now inferred from the protocol in the http.api.url
- Added http.connect.timeout.ms and http.request.timeout.ms config properties
Version 1.3.1
- CCDB-3991: Do not log request payload
Version 1.3.0
- FF-4677;FF-4679: Add feature to post individual records with HttpSinkConnector
- CCDB-3811: bump reporter dep version to 0.1.5
- CCDB-3809: Use proxy when issuing OAuth requests
- CC-12594: Mark NoHttpResponseException and SocketException as retriable
- Clear batch when request fails
- Change flag in pom to run integration tests
Version 1.2.4
- CCDB-3811: bump reporter dep version to 0.1.5
Version 1.2.3
- CCDB-3809: Use proxy when issuing OAuth requests
Version 1.2.2
- CC-12594: Mark NoHttpResponseException and SocketException as retriable
Version 1.2.1
- Clear batch when request fails
- Change flag in pom to run integration tests
Version 1.2.0
- CCDB-3675 : Update Http Sink connector to send failed request response as payload to reporter
- Revert “Noretry code” (second file)
- Improving an existing debug log for Support/Retry should be logged at…
- Update Docs URL update
- CC-13191: Enable integration tests in Jenkins for HTTP Sink
Version 1.1.2
- CCDB-3809: Use proxy when issuing OAuth requests
Version 1.1.1
- CC-12594: Mark NoHttpResponseException and SocketException as retriable
- Change flag in pom to run integration tests
- Improving an existing debug log for Support/Retry should be logged at…
- Update Docs URL update
- CC-13191: Enable integration tests in Jenkins for HTTP Sink
Version 1.1.0
- CC-12031: Fix CVEs in HTTP Sink connector
- HCD-288 Added header support
- HCD-281 JSON support added
- FF-2903: Added reauthenticaton backoff-retry when a 401 UNAUTHORIZED
- CC-10063: Include the string formatter for the reporter
- CC-9825: HTTP Sink connector does not encode record key/topic if used within the URL
- MINOR: Validate regex configs during config construction
- CC-9634: Upgrade connect-reporter:0.1.4 to make bootstrap servers optional
- CC-8983: Allow empty HTTP response body
- CC-8380: Retry on HTTP connection exceptions
- CC-7640: Added validation to ensure
http.api.url
not being null
- CC-8077: Implement configurable error code retries
- MINOR: Close reporter when stopping task
- CC-6953: Make the SSL endpoint identification algorithm configurable
- MINOR: Retry with 4XX errors as well
- CC-7988: Non-retriable errors must be reported
- CC-7862: Add exponential backoff and skip retrying on 4XX HTTP errors
- Integrated reporter framework to produce responses into a configured Kafka topic
- CC-5130: Allows uppercase and lowercase for
REQUEST_METHOD
configuration
- Fix encoding for payload
Version 1.0.19
- CCDB-3811: bump reporter dep version to 0.1.5
Version 1.0.18
- CCDB-3809: Use proxy when issuing OAuth requests
Version 1.0.17
- Automatically retry on NoHttpResponseException and SocketException errors from connection issues.
- Improve debug logging for failed requests
- Rename config property batch.seperator to batch.separator
- Add Kafka headers to HTTP request headers if present
Version 1.0.16
- Added support for JSON request body format.
Version 1.0.15
- Added reauthenticaton backoff-retry when a 401 UNAUTHORIZED response is received.
Version 1.0.14
- Add a
string
option when configuring the formatter for the result and error reporter.
Version 1.0.13
- Correctly encode the URL when formatting it with an input record key and/or topic.
- Log an error if the lengths of the configurations (
regex.patterns
and regex.replacements
) are different.
Version 1.0.12
- Fix bug where reporter.bootstrap.servers was required when no reporter topics were configured.
Version 1.0.11
- Gracefully handle empty HTTP response body from the server, which was incorrectly leading to EOF exceptions in the connector.
Version 1.0.10
- A HTTP request that times out or fails due to connection issues will be retried according to the connector configuration.
Version 1.0.9
- Added validation to ensure the http.api.url is not null. If SSL is enabled, validation ensures truststore configuration properties are not null.
- Allow missing keystore properties.
Version 1.0.8
- Fixed bug where https.ssl.endpoint.identification.algorithm worked as expected only when set to https.
Version 1.0.7
- Connector will now backoff and retry on 4xx errors.
Version 1.0.6
- Non-retriable errors are also be reported.
Version 1.0.5
- Add exponential backoff and retries on 5xx errors.
- Integrated reporter framework to produce success and error responses into a configured Kafka topic.
Version 1.0.4
- Use UTF-8 to encode payload sent to HTTP server.
Version 1.0.3
- Added configuration to set the scope parameter when making Oauth authorization requests.
- Added configuration to select between encoding the client credentials either in the HTTP header or as a URL parameter.
Version 1.0.2
- CP-635: Support ‘:’ in header values
Version 1.0.1
- Promote connector to General Availability
Version 1.0.0-preview
- Initial version for preview