Changelog for Amazon Kinesis Source Connector for Confluent Platform

Version 1.3.27

  • Update AWS STS version to match Kinesis Client, Protobuf-java CVE fix

Version 1.3.26

  • Fixed ion-java CVE

Version 1.3.25

  • Fixed Jackson databind CVE

Version 1.3.24

  • Added validations for empty.records.backoff.ms and throughput.exceeded.backoff.ms

Version 1.3.23

  • Fixed CVE for: org.bitbucket.b_c_jose4j and com.fasterxml.jackson.core_jackson-databind

Version 1.3.22

  • Fixed CVE-2023-51775

Version 1.3.21

No changes

Version 1.3.20

  • CVE Fix
  • Version Test FIx in Kinesis Source UT

Version 1.3.19

  • Increase Kinesis Test Shard Update Timeout
  • Update KinesisSourceConnectorTest.java
  • Jackson-Databind CVE Fix
  • [TD] auto-commit : update connect-templates to v0.44.0
  • [TD] auto-generate template-decoupling changes for single-module connectors

Version 1.3.18

  • ESC-581: pin dependencies to address CVE escalation

Version 1.3.17

  • CCMSG-2352 fix for CVE-2022-31159:

Version 1.3.16

  • Fix region computation logic to allow specifying GovCloud / us-gov-west-1 as a region

Version 1.3.15

  • CCMSG-2265: Skip distribute completed shards to tasks
  • CCMSG-2221 | CVE fix for jackson databind dependency.

Version 1.3.14

  • CCMSG-2132: Support Kinesis Record De-Aggregation when source is sending aggregated records using KPL

Version 1.3.13

No changes

Version 1.3.12

  • Update poll method to continue processing remaining task shards on throughput exceptions

Version 1.3.11

  • CCMSG-1944 Replaced confluent-log4j by reload4j for CVE fix

Version 1.3.10

  • Minor:Upgrade connect-commons-plugins from 0.8.12 to 0.8.13 to use backward compatible licensing jar
  • Minor:Upgrade connect-commons-plugins from 0.8.11 to 0.8.12 to remove nano version
  • CVE: Upgrade connect-commons-plugins from 0.8.10 to 0.8.11
  • CCMSG-1726 updated to latest commons to fix jackson-databind CVE
  • CCMSG-1645 Resolved protobuf CVEs by upgrading to latest commons

Version 1.3.9

  • CCMSG-1703: Catch exception when validating a null stream name

Version 1.3.8

  • CCMSG-1597 Upgrade log4j to 1.2.17-cp8
  • CCMSG-1023: Upgrade parent to 0.6.5 and resolve CVE in jackson dataformat cbor

Version 1.3.7

  • CCMSG-940: Pass all configs to configured credentials provider

Version 1.3.6

No changes

Version 1.3.5

  • CCMSG-935: Set region when building credentials
  • CCMSG-870: Add validation for a stream that is in the process of deletion
  • CCMSG-922: Connector passes incorrect credentials provider configs
  • CCMSG-765: Fix NPE in getCredentialsProvider when accessKey is null.
  • CC-14146: Do not require wildcard kinesis:ListStreams permission.

Version 1.3.4

  • CCMSG-922: Fix passing wrong credentials provider configs
  • CCMSG-765: Fix NPE in getCredentialsProvider when access key is null
  • CC-14146: Do not require wildcard kinesis:ListStreams permission

Version 1.3.3

  • CCMSG-812: Kinesis Source validations do not respect kinesis.base.url config

Version 1.3.2

  • MINOR: Upgrade HttpClient to 4.5.13 and Guava to 30.1-jre to resolve CVEs
  • CC-13061: Upgrade Jackson databind version to 2.10.5.1 to address CVE
  • CC-12763: Handle Expired iterators in poll() method

Version 1.3.1

  • Update parent pom of connect plugins common to 0.5.5
  • Fix NPE from not removing finished shard from shard assignment
  • Deprecating kinesis.throughput.exceeded.backoff.ms which will be removed in release 2.0.0
  • Handle null (closed) shards
  • Deprecating proxy auth configuration which will be removed in release 2.0.0

Version 1.3.0

No changes

Version 1.2.5

  • CCMSG-1944 Replaced confluent-log4j by reload4j for CVE fix

Version 1.2.4

  • CCMSG-1023: Upgrade parent to 0.6.5 and resolve CVE in jackson dataformat cbor
  • CCMSG-940: Pass all configs to configured credentials provider
  • CCMSG-935: Set region when building credentials
  • CCMSG-870: Add validation for a stream that is in the process of deletion
  • CCMSG-922: Fix connector passing incorrect credentials provider config
  • CCMSG-765: Fix NPE in getCredentialsProvider when accessKey is null.
  • CC-14146: Do not require wildcard kinesis:ListStreams permission.

Version 1.2.3

  • CCMSG-812: Kinesis Source validations do not respect kinesis.base.url config

Version 1.2.2

  • MINOR: Upgrade HttpClient to 4.5.13 and Guava to 30.1-jre to resolve CVEs
  • CC-13061: Upgrade Jackson databind version to 2.10.5.1 to address CVE
  • CC-12763: Handle Expired iterators in poll() method

Version 1.2.1

  • Update connect plugins common to 0.5.5
  • Fix NPE from not removing finished shard from shard assignment
  • Deprecating kinesis.throughput.exceeded.backoff.ms which will be removed in release 2.0.0
  • Handle null (closed) shards
  • Deprecating proxy auth configuration which will be removed in release 2.0.0

Version 1.2.0

  • Added proxy support for connector
  • CC-11126: Recover more gracefully on invalid offsets
  • CC-11262: Updated AWS SDK to 1.11.728
  • CC-9318: Add AWS STS dependency for AssumeRole support
  • CC-11156: Configure retry policy to retry for longer
  • CC-3656: Allow reading multiple shards per task
  • FMC-536: Add connector config validations
  • FMC-539: Add timestamp config for kinesis.position=AT_TIMESTAMP
  • Remove AT_SEQUENCE_NUMBER and AFTER_SEQUENCE_NUMBER as valid positions
  • FMC-513: Refactor Kinesis Source connector and integration tests
  • FMC-372: Allow changing Kinesis stream config and restarting the connector
  • MINOR: Accept lowercase-regions as valid region names

Version 1.1.16

  • CCMSG-1944 Replaced confluent-log4j by reload4j for CVE fix

Version 1.1.15

  • CCMSG-1023: Upgrade parent to 0.6.5 and resolve CVE in jackson dataformat cbor

Version 1.1.14

  • CCMSG-940: Pass all configs to configured credentials provider
  • CCMSG-935: Set region when building credentials
  • CCMSG-870: Add validation for a stream that is in the process of deletion
  • CCMSG-922: Fix connector passing incorrect credentials provider config
  • CCMSG-765: Fix NPE in getCredentialsProvider when accessKey is null
  • CC-14146: Do not require wildcard kinesis:ListStreams permission

Version 1.1.13

  • CCMSG-812: Kinesis Source validations do not respect kinesis.base.url config

Version 1.1.12

  • MINOR: Upgrade httpclient to 4.5.13 and Guava to 30.1-jre to resolve CVEs
  • CC-13061: Upgrade jackson databind version to 2.10.5.1 to address CVE
  • CC-12763: Handle expired iterators in poll() method

Version 1.1.11

  • Update connect plugins common to 0.5.5
  • Fix NPE from not removing finished shard from shard assignment
  • Deprecating kinesis.throughput.exceeded.backoff.ms which will be removed in release 2.0.0
  • RCCA-1685: Handle null (closed) shards

Version 1.1.10

  • CC-11262: Updated AWS SDK to 1.11.728
  • MINOR: Improved trace level logging

Version 1.1.9

  • CC-11156: Configure retry policy to retry for longer
  • CC-11126: Recover more gracefully on invalid offsets

Version 1.1.8

  • CC-9318: Add AWS STS dependency for AssumeRole support

Version 1.1.7

  • CC-3656: Allow reading multiple shards per task
  • FMC-536: Add connector config validations
  • FMC-539: Add timestamp config for kinesis.position=AT_TIMESTAMP
  • Remove AT_SEQUENCE_NUMBER and AFTER_SEQUENCE_NUMBER as valid positions

Version 1.1.6

  • MINOR: Bump Jackson version to 2.10.4
  • FMC-372: Allow changing Kinesis stream config and restarting the connector

Version 1.1.5

  • MINOR: Remove duplicate dependencies
  • CC-8916: Bump Jackson version to 2.9.10
  • MINOR: Accept lowercase-regions as valid region names
  • CC-7575: Update integration test framework dependencies

Version 1.1.4

  • CC-4956: Upgrade AWS client library to 1.10.0 and Jackson to 2.9.8

Version 1.1.3

  • Return correct connector version information to Connect REST API

Version 1.1.2

  • Updated support terms and promote Kinesis connector to PA

Version 1.1.1-Preview

  • CC-3696: Jackson libraries reverted back to v2.6.7 to match version in AWS SDK

Version 1.1.0-Preview

Initial version