Releases: lensesio/kafka-connect-smt
Releases · lensesio/kafka-connect-smt
Release v1.3.2
Adds support for multiple "from" patterns.
This converts the format.from.pattern
field in the following SMTs:
InsertRollingFieldTimestampHeaders
InsertRollingRecordTimestampHeaders
InsertRollingWallclockHeaders
TimestampConverter
into a List (comma separated) so that these SMTs can support multiple (fallback) DateTimeFormatter patterns should multiple timestamps be in use.
Release v1.3.1
v1.3.1 - increase error information for debugging
Release v1.3.0
Adds support for adding metadata to kafka connect headers (for a source connector).
Full Changelog: v1.2.1...v1.3.0
Release v1.2.1
Workaround for Connect runtime failing with unexplained exception where it looks like the static fields of parent class is not resolved properly.
Full Changelog: v1.2.1...v1.2.1
Release v1.2.0
Adds support for inserting time based headers using a Kafka message payload field
Full Changelog: v1.2.0...v1.2.0
Release v1.1.2
Fix public visibility of rolling timestamp headers (#10) Co-authored-by: stheppi <[email protected]>
Release v1.1.1
SMTs ctors visibility (#8) Some of the SMTs introduced recently had the ctor visibility set to protected. Co-authored-by: stheppi <[email protected]>
v1.1.0
What's Changed
- Introducing four new Single Message Transforms (SMTs) aimed at simplifying and streamlining the management of system or record timestamps, along with support for rolling windows. These SMTs are designed to significantly reduce the complexity associated with partitioning data in S3/Azure/GCS Sink based on time, offering a more efficient and intuitive approach to data organization. By leveraging these SMTs, users can seamlessly handle timestamp-based partitioning tasks, including optional rolling window functionality, paving the way for smoother data management workflows. by @stheppi in #6
Full Changelog: v1.0.4...v1.1.0
Release v1.0.4
What's Changed
- Enhancement: Support Record Timestamp for Data Partitioning by @stheppi in #4
- Timezone support by @stheppi in #5
Full Changelog: v1.0.3...v1.0.4