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)

v1.0.3

Changelog

[1.0.3] (2024-09-03)

Improvements

• Improved the offsets management and logging in the ConsumerLoop class.

• Modified the quickstart-producer sample client project to make it publishable to GitHub Packages.

• Deeply refactored the classes and interfaces of the com.lightstreamer.kafka.connect package to enhance loose coupling and facilitate testability.

• Improved the unit tests relative to the Sink connector.

Documentation

Modified the README.md file has follows:

• Added the Supported Converters section, clarifying the supported converters for the Sink connector.

• Stated the Kafka Connect framework version for which the Sink connector has been developed.

• Mentioned the Confluent Platform version to which the Sink connector can be deployed.

• Added the tasks.max section, clarifying the impact of the tasks.max property on the Sink connector configuration.

• Removed incomplete statements.

Bug Fixes

• The Sink connector enabled the creation of multiple tasks, despite the one-to-one relationship between ProxyAdapter and task.

• A Converter configured without schema support triggered an exception, leading to an unexpected interruption of the Sink connector.

v1.0.2

Changelog

[1.0.2] (2024-08-26)

Improvements

• Improved README.md by restructring the Topic Mapping section.

Bug Fixes

• Fixed reference to the com.lightstreamer.kafka.adapters.pub.KafkaConnectorMetadataAdapter class in several resource files. (#4)

v1.0.1

[1.0.1] (2024-08-23)

Improvements

• Added the Project Report Plugin to the project to generate reports contaning information about the build.

• Added dependency on javadoc task to the build task in the build.gradle file.

Bug Fixes

• The following configuration parameters for the Sink Connector:

  • lightstreamer.server.proxy_adapter.username
  • lightstreamer.server.proxy_adapter.password

  were being ignored.

• The com.lightstreamer.kafka.connect.config.LightstreamerConnectorConfigTest class contained a test producing unwanted output files.

• The examples/docker-kafka-connect/README.md file contained a wrong reference to the Docker image name.

• The gradle.properties file contained an unsed property.

• The README.md contained broken links.