Implemented enhancements:
Fixed bugs:
- Kafka connector's
client.id
configuration option is ignored during message publishing. #186 - In a batch request each message should be in its own batchspec #171
Implemented enhancements:
- Provide option to specify encoding for Ably Message using special Kafka header #158
4.0.0 (2023-09-21)
This is a major release and contains a number of breaking changes. Please see the upgrade guide for more information on how to upgrade from version 3.x.
Implemented enhancements:
This is a major release and contains a number of breaking changes. Please see the upgrade guide for more information on how to upgrade from version 2.x.
Closed issues:
- Support multiple
SinkTask
instances #138 - Remove orphaned config #135
- Support
Struct
fields in chanel and message name mapping #134 - Configurable buffering of incoming records #133
- Submit records using Batch API #124
- Test on MSK #123
- Offset tracking and committing #121
- Integration Testing #120
- DLQ Error Handling #119
Merged pull requests:
- docs: readme entry for Confluent Cloud BYOC #147 (AndyTWF)
- v3.0.0 #146 (AndyTWF)
- Documentation and Config updates #142 (jaley)
- Structured field access for channel and message name mappings #141 (jaley)
- Support multiple tasks #140 (jaley)
- Remove legacy config and documentation #139 (jaley)
- Restore integration tests and fix related bugs #137 (jaley)
- Buffer incoming
SinkRecords
before sending batches #132 (jaley) - End to end testing #131 (jaley)
- Added OffsetRegistryService class to store offsets by kafka topic/par… #130 (subkanthi)
- MSK Packaging & Example Deployment #129 (jaley)
- Kafka DLQ #128 (subkanthi)
- Update to Confluent Platform 7.4.0 #127 (jaley)
- Fix Docker build errors #126 (jaley)
- Batch API changes, create Threadpoolexecutor, add logic to batch mess… #125 (subkanthi)
Fixed bugs:
- Republish messages that were canceled after connection suspension #106
Implemented enhancements:
- Use record headers to add push payload #101
Closed issues:
- Add support for String keys #98
Merged pull requests:
Implemented enhancements:
Implemented enhancements:
- Provide ability for users to channel failed messages into a dead letter queue #90
- Provide ability to skip a record when a key is absent and channel is configured with a key #85
- Update docker-compose to include latest version of images #81
Fixed bugs:
- Support for nullable structs' conversion #86
Merged pull requests:
This release increases ably-java dependency version to fix a potential vulnerability issue in dependency used by ably-java.
Merged pull requests:
v2.0.1 (2022-06-01)
This release increases the capability of this connector to process data types received from Kafka Connect, with support for JSONifying schematic data #71, implemented in #73 (ikbalkaya).
v2.0.0 (2022-04-20)
Implemented enhancements:
- Remove client.use.binary.protocol configuration #57
- Add configuration validators #53
- Make message name configurable and interpolable #46
- Code reorganization and refinement #63 (ikbalkaya)
- Add distributed mode configuration file #62 (ikbalkaya)
- Remove client.use.binary.protocol configuration #60 (ikbalkaya)
- Make message name configurable #48 (ikbalkaya)
- Implement pattern based mapping #43 (ikbalkaya)
Fixed bugs:
- Readme emphasizes n to 1 mapping #66
- NullPointerException when proxy password is not specified #34
- NullPointerException on proxy port issue #52 (ikbalkaya)
v1.0.3 (2021-12-31)
Fixed bugs:
v1.0.2 (2021-09-29)
Merged pull requests:
- Document the release process #31 (lmars)
- Set 'kafka-connect-ably' in the Ably-Agent header #30 (lmars)
- Conform license and copyright #28 (QuintinWillison)
- Conform overview section of readme #27 (QuintinWillison)
- Add Maven version for those using ASDF or compatible tooling #26 (QuintinWillison)
- Explicitly specify workflow
permissions
required to succeed when our org switches default access from 'permissive' to 'restricted' #25 (QuintinWillison)
v1.0.1 (2021-08-25)
Closed issues:
- Issue when installing the connector #18
- Issue when installing the connector #17
- Review Kafka code for Tech Preview #16
- test #15
- Publish to Confluent Hub #13
- Review Kafka code for Tech Preview #12
- Review Kafka code for Tech Preview #11
Merged pull requests:
- Add ownerLogo #24 (lmars)
- Add logo #23 (lmars)
- Refactor project code #22 (KacperKluka)
- Use consistent naming: 'Ably Kafka Connector' #20 (lmars)
- Fix build failure relating to Kafka Connect parent POM #19 (QuintinWillison)
v1.0.0 (2021-06-24)
Implemented enhancements:
- Test issue #2
Closed issues:
- Update configuration and running locally docs #8
- Migrate kafka-connect-ably Java packages from io.ably to com.ably #7
- Write tests for Kafka Connect Library #4
- Sync test 2 #3
Merged pull requests:
- DOC-303: Update README with configuration properties and installation instructions #14 (m-hulbert)
- Rename package from io.ably.kakfa.* to com.ably.kafka.* #10 (lmars)
- Update configuration and running locally docs #6 (lmars)
- Add integration test #5 (lmars)
- Put Kafka key and headers in Ably message extras #1 (lmars)
* This Changelog was automatically generated by github_changelog_generator