Skip to content

Releases: ably/kafka-connect-ably

4.1.1

19 Jul 14:35
120b94e
Compare
Choose a tag to compare

Full Changelog

Implemented enhancements:

  • Update ably-java dependency #181
  • Encryption support feature request [parked] #169

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

4.1.0

20 Oct 15:15
bac681d
Compare
Choose a tag to compare

Implemented enhancements:

  • Provide option to specify encoding for Ably Message using special Kafka header #158

4.0.0

22 Sep 08:44
bfd88c1
Compare
Choose a tag to compare

Implemented enhancements:

  • Stringify Kafka headers before send them to Ably #155
  • Flatten Kafka headers in extras #155

3.0.0

06 Jul 13:47
d1586fb
Compare
Choose a tag to compare

Full Changelog

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)

2.1.4

28 Mar 12:59
57f04b1
Compare
Choose a tag to compare

Full Changelog

2.1.3

14 Mar 15:27
594c86e
Compare
Choose a tag to compare

What's Changed

Fixed bugs:

  • Republish messages that were canceled after connection suspension #106

Full Changelog: v2.1.2...v2.1.3

2.1.2

21 Feb 13:49
04a0143
Compare
Choose a tag to compare

What's Changed

Full Changelog: v2.1.1...v2.1.2

2.1.1

14 Feb 13:55
39c9261
Compare
Choose a tag to compare
  • Add logical type support to Json converter by @ikbalkaya in #99

Full Changelog: v2.1.0...v2.1.1

2.1.0

09 Nov 10:06
cbee26f
Compare
Choose a tag to compare

Full Changelog

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

2.0.3

16 Sep 16:54
3bbada4
Compare
Choose a tag to compare

Full Changelog

Fixed bugs:

  • Support for nullable structs' conversion #86

Merged pull requests:

  • Fix NullPointerException issue when null struct value is provided to Json converter #87 (ikbalkaya)