1. Home
  2. Kafka Connectors

Changelog

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