- Fixed an issue where using
CosmosDBSinkConnector
in bulk mode failed to write items for container with nested partition key path - PR 565
- Fixed an issue where only 1 task run successfully when
CosmosDBSourceConnector
is configured withmaxTasks
larger than1
- PR 561
- Fixed
NullPointerException
inCosmosDBSourceConnector
. PR 555
- Updated
azure-cosmos
version to 4.56.0.
- Fixed
NullPointerException
inCosmosDBSinkConnector
whenTRACE
level log is enabled andSinkRecord
value being null. PR 549
- Added more DEBUG level logs in
CosmosDBSourceConnector
. PR 549
- Updated
azure-cosmos
version to 4.54.0.
- Upgraded
com.jayway.jsonpath:json-path
from 2.8.0 to 2.9.0 to address the security vulnerability. PR 544 https://cve.mitre.org/cgi-bin/cvename.cgi?name=CVE-2023-51074 - Fixed an issue where source connector can be stuck in an infinite loop when task got cancelled. PR 545
- Updated
azure-cosmos
version to 4.53.1.
- Updated
azure-cosmos
version to 4.52.0.
- Construct
SourceRecord
offset based on_lsn
from the item inCosmosDBSourceConnector
. PR 534
- Added compression feature to resolve duplicate records in a single batch when consuming from kafka topic in the bulk mode for sink connector through new config
connect.cosmos.sink.bulk.compression.enabled
. PR 515 - Updated
azure-cosmos
version to 4.51.0.
- Added documentation and infrastructure for testing in distributed mode using confluent cloud integration. PR 528
- Updated
azure-cosmos
version to 4.46.0.
- This change will stop updating the lease container continuation token based on kafka offset when using the config
connect.cosmos.offset.useLatest
. PR 516
When set to false
, if the lease container exists, connector will now process the changes from the current continuationToken in leaseContainer
, if the lease container does not exist, then it will start processing the changes from beginning.
If you want to start from beginning, it is advised to delete the lease container or change the kafka worker name.
when set to true
, if the lease container exists, connector will now process the changes from the current continuation token in leaseContainer
, if the lease container does exist, then it will start processing the changes from now.
- Fixed issue in
CosmosDBSourceConnector
where no record being read when configuredconnect.cosmos.offset.useLatest
to be false. PR 516
- Return from
poll
method once all records have been processed from the changeFeedProcessor batches. PR 517
- Updated
azure-cosmos
version to 4.42.0. - Updated
json-path
version to 2.8.0. - Updated
kafka-connect
version to 2.8.2.
- Fixed issue in Sink Connector for nested maps in Struct types. PR 510
- Fixed issue in Sink Connector when using
AvroConverter
. PR 503
- Updated
azure-cosmos
version to 4.41.0.
- Added bulk support for
CosmosDBSinkConnector
. - PR 485 - Added gateway mode support for
CosmosDBSinkConnector
andCosmosDBSourceConnector
. - PR 490
- Updated
azure-cosmos
version to 4.36.0.
- Fixed parsing for empty arrays. PR 466
- Updated
CosmosDBSinkConnector
to keep retrying for throttled requests. - PR 472
- Updated
azure-cosmos
version to 4.30.0.
- Fixed an issue of missing records in Kafka topic if record size is larger than
connect.cosmos.task.buffer.size
- PR 457 - Fixed an issue of getting
Invalid endpoint
exception when endpoint is valid - PR 459
- Fixed parsing of 64 bit values - PR 451
- Added error tolerance config into CosmosDBSink - PR 443
- Added endpoint/key config validation - PR 446
- Updated
kafka-connect
version to 2.8.1. - Updated
azure-cosmos
version to 4.25.0.
- Fixed NullPointerException issue with nullable structs. See this PR 439.
- Upgraded log4j2 to 2.17.1 to address the security vulnerability https://cve.mitre.org/cgi-bin/cvename.cgi?name=CVE-2021-44832
- Upgraded log4j2 to 2.17.0 to address the security vulnerability https://cve.mitre.org/cgi-bin/cvename.cgi?name=CVE-2021-45105
- Upgraded log4j2 to 2.16.0 to address the security vulnerability https://cve.mitre.org/cgi-bin/cvename.cgi?name=CVE-2021-45046
- Upgraded log4j2 to 2.15.0 to address the security vulnerability https://cve.mitre.org/cgi-bin/cvename.cgi?name=CVE-2021-44228
- Updated
azure-cosmos
to v4.21.1
- TODO
- TODO
- TODO
- TODO
- TODO
- TODO
- TODO
- TODO
- TODO
- TODO
- Updates to the mainfest.json for release to refresh metadata on Confluent Hub
- This is the first public preview release for both Sink and Source Connectors which is also published on Confluent Hub.
- Enhanced Integration Tests.
- Added support for standalone mode.
- Updated documentation and minor fixes.
- Checkstyle Implementation.