v1.2.1-kvp

Changelog

[1.2.1-kvp] (2025-01-02)

Improvements

• Added support for KVP (Key Value Pairs) format.

[1.2.0] (2025-01-02)

Improvements

• Upgraded Gradle to version 8.12. (#37)

• Added support for skipping failures while mapping fields (also available for the Sink connector). (#34)

• Added support for topic mappings declared as regular expressions (also available for the Sink connector). (#33, #35)

• Optimize processing when there are no routable items. (#30)

Bug Fixes

• Fixed unit tests to support version numbers that may include pre-release indentifiers. (#38)

• Fixed the Docker build in the Airport demo. (#36)

• Fixed the name of the record.mappings parameter. (#34)

• Fixed evaluation of template expressions. (#32)

• Fixed exceptions management of single-threaded processing. (#31)

v1.2.0

Changelog

[1.2.0] (2025-01-02)

Improvements

• Upgraded Gradle to version 8.12. (#37)

• Added support for skipping failures while mapping fields (also available for the Sink connector). (#34)

• Added support for topic mappings declared as regular expressions (also available for the Sink connector). (#33, #35)

• Optimize processing when there are no routable items. (#30)

Bug Fixes

• Fixed unit tests to support version numbers that may include pre-release indentifiers. (#38)

• Fixed the Docker build in the Airport demo. (#36)

• Fixed the name of the record.mappings parameter. (#34)

• Fixed evaluation of template expressions. (#32)

• Fixed exceptions management of single-threaded processing. (#31)

v1.1.1-kvp-2

Add support for topic mappings declared as regular expressions

v1.1.1-kvp

Enables support for KVP (Key Value Pairs) format

v1.0.8-command

[1.0.8-command] (2024-12-16)

• Added explicit support for COMMAND mode subscriptions, including the new configuration parameter "record.command.enable" to enable this feature. Behavior Notes:

  • By sending messages with the special key snapshot and specifying the values CS or EOS in the command field, the Kafka connector will interpret these as special events rather than regular updates.
  • The connector will trigger the corresponding events in the DataProvider interface.
  • For Clear Snapshot (CS): This event will always be communicated to all clients subscribed to the item.
  • For End-of-Snapshot (EOS): Communication to clients depends on the internal state reconstructed by the Lightstreamer server. If the server has already determined that the snapshot has ended, the event might be ignored.

• Updated the Airport demo to use COMMAND mode.

v1.1.0

Changelog

[1.1.0] (2024-12-11)

Improvements

• Added support for concurrent processing, along with deep refactoring of the code base for better performance. (#29)

• Upgraded Gradle to version 8.11.1. (#29)

Documentation

• Added some style changes to the README.md and factory adapters.xml files. (#28)

• Introduced the Client Side Error Handling section in the README.md file. (#17)

v1.0.7

Changelog

[1.0.7] (2024-11-06)

Improvements and Documentation

• Revised some default settings for the internal Kafka consumer. (#25)

• Improved the README.md file. (#18, #20, #21, #22)

• Significantly reorganized the examples folder. Specifically:

  • Moved the quick start examples for specific vendors (Confluent, Redpanda, Aiven, and Axual) into dedicated subfolders under examples/vendors. (#20, #23, #24)

  • Adjusted the script files to align with the updated layout of the examples folder. (#20)

  • Improved the docker-compose.yml and README.md files within the quick start folders. (#20)

  • Improved the README.md files within examples/docker and examples/docker-kafka-connect folders. (#20)

  • Introduced a dedicated README.md file for Confluent Cloud along with further specific resources under examples/vendors/confluent. (#20, #22, #26)

  • Added new resources to the pictures folder. (#18, #20, #22)

  • Added a new data adapter configuration named QuickStartConfluentCloud to the factory adapters.xml file. (#22)

  • Added a new logger configuration named QuickStartConfluentCloud to the factory log4j.properties file. (#22)

  • Improved the QuickStart web client by refactoring the JavaScript coied and using the CDN version of the Lightstreamer client library. (#22)

Bug Fixes

• Unhandled runtime exceptions during synchronous commits prevented the fulfillment of new subscription requests. (#27)

v1.0.6

Changelog

[1.0.6] (2024-10-10)

Documentation

• Updated the manifest.json file embedded in the Sink connector archive. (#15)

• Updated the README.md and factory adapters.xml files to explain how to configure Basic HTTP authentication for the Schema Registry. (#16)

v1.0.5

Changelog

[1.0.5] (2024-09-25)

Improvements

• Added the etc folder to the Sink connector zip file. (#14)

v1.0.4

Changelog

[1.0.4] (2024-09-10)

Documentation

• Updated the README.md file to explain how to use either the configuration properties file or the configuration JSON file to run the Sink connector. In addition, examples of JSON files have been provided under the kafka-connector-project/config/kafka-connect-config folder. (#8)

• Consistently updated all references to Java as "JDK version 17" throughout the project. (#9)

• Clarify the JDK version required to run the Sink connector. (#10)

• Updated the manifest.json file embedded in the Sink connector archive. (#13)

• Made some additional minor fixes. (#12)

Improvements

• Introduced automatic configuration of the client.id consumer property when connected to Confluent Cloud. (#11)