Releases: SolaceProducts/pubsubplus-connector-kafka-source
Releases · SolaceProducts/pubsubplus-connector-kafka-source
v3.2.0
Improvements
- Upgrade JCSMP to
10.27.0 - Upgrade Kafka compile-time to
3.9.0 - Remove bundled Kafka libraries to fix collision with Kafka runtime which already has them.
Known Issues
- If you had implemented your own Message Processor, you will need to manually include the Kafka Connect API as a dependency for your processor to compile.
v3.1.0
Improvements
- Add support for mapping Solace message user properties to Kafka record Headers
- Add support for mapping Solace message properties to Kafka record headers
- Add
sol.message_processor.map_user_propertiesconfig option to manage mapping Solace message user properties to Kafka record Headers (default:false) - Add
sol.message_processor.map_solace_standard_propertiesconfig option to manage mapping Solace message standard properties to Kafka record Headers (default:false) - Update sample message processors
SolSampleSimpleMessageProcessor.javaandSolaceSampleKeyedMessageProcessor.javato use new message header injection based on added configuration properties. - Upgrade JCSMP to
10.22.0
v3.0.1
v3.0.0
v2.3.0
v2.1.0
Improvements
- Upgrade Kafka to 2.8.1
- Upgrade JCSMP to 10.12.0
Bug Fixes
- Fix password obfuscation (#30)
- Fix task start error propagation (#32)
- Add
sol.message_processor.error.ignoreconfig option to discard messages that produce message processor errors (#33)
Misc
- Use ephemeral ports for test infrastructure setup (#29)
- Fix Gradle
integrationTesttask and addedtesttask - Add Dependabot
- Add Jacoco code coverage
- Add static code analysis tools (CodeQL, PMD, SpotBugs)
- Upload test results to Github Action
v2.0.2
- Fixed and fine-tuned tight spin lock at poll which can result in 100% CPU if no new messages
- Fixed leak in processor object use
v2.0.0
- Updated build scripts
- Code refactoring and stability fixes
- Added automated integration testing
- Updated documentation
- Packages available from download pages
Initial release
Initial release to satisfy Jira https://sol-jira.atlassian.net/browse/SOL-8496