Releases: siddhi-io/siddhi-io-kafka
Siddhi IO Kafka Release 5.0.16
What's Changed
- Remove kafka dependencies by @lasanthaS in #153
- Add log4j1 as a test dependency by @AnuGayan in #154
- Upgrade log4j1 to 2.17.1 by @dnwick in #150
- Add support for message decoding via Schema registry by @lasanthaS in #149
- Send events to error handlers when broker is unavailable by @dilini-muthumala in #144
- Add Kafka Sink Error Stream Test case by @dilini-muthumala in #145
- Change repo URLs to https in pom.xml files of master by @senthuran16 in #146
- Bump siddhi version by @AnuGayan in #147
Full Changelog: v5.0.12...v5.0.16
Contributors
Assets 2
Siddhi IO Kafka Release 5.0.12
Siddhi IO Kafka Release 5.0.7
This Release is compatible with Siddhi 5.x.x
Overview
Siddhi IO Kafka 5.0.7 release contains bug fixes for possible NPEs and bug fixes related to Kafka partition handling.
Bug Fixes
- Possible NPE when restoring Siddhi state (#122)
- Partition wise thread setting not working as expected (#121)
Complete Changes
Please find the complete changes here
Download
Download the release from here
Siddhi IO Kafka Release 5.0.6
This Release is compatible with Siddhi 5.x.x
Overview
Siddhi IO Kafka 5.0.6 release contains improvement related to support handle over committing the offset at Kafka Source.
Please find below table depicting how enable.offsets.commit and enable.auto.commit needs to be configured to achieve the required behabiour.
| enable.offsets.commit | enable.auto.commit | Behaviour |
|---|---|---|
| true | true | Commit offset periodically |
| true | false | Commit offset maually |
| false | true | Would not commit |
| false | false | Would not commit |
Bug Fixes
- auto.offset.reset:latest not honored (#91)
Complete Changes
Please find the complete changes here
Download
Download the release from here
Siddhi IO Kafka Release 5.0.5
This Release is compatible with Siddhi 5.x.x
Overview
Siddhi IO Kafka 5.0.5 release contains improvement related to configuring offset committing at Kafka Source.
Bug Fixes
- Relatively low consuming rates (#117)
Complete Changes
Please find the complete changes here
Download
Download the release from here
Siddhi IO Kafka Release 5.0.4
This Release is compatible with Siddhi 5.x.x
Overview
Siddhi IO Kafka 5.0.4 release contains bug fixes released to Kafka Source connection handling and retry logic related issues.
Bug Fixes
- Kafka source connection retry related fixes (#112)
- Issue of Kafka connection creation in init method (#112)
Complete Changes
Please find the complete changes here
Download
Download the release from here
Siddhi IO Kafka Release 5.0.3
This Release is compatible with Siddhi 5.x.x
Overview
Siddhi IO Kafka 5.0.3 release contains a bug fix related Kafka IO annotation.
Highlights
- Renamed topic.offset.map configuration parameter to topic.offsets.map
Bug Fixes
- Setting 'topic.offset.map' parameter gives Siddhi Parse Error on siddhi app deployment. (#103)
Complete Changes
Please find the complete changes here
