You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gh...@apache.org on 2024/07/08 18:10:00 UTC
(kafka) branch trunk updated (a533e246e3e -> e2ec389a7c6)
This is an automated email from the ASF dual-hosted git repository.
gharris pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from a533e246e3e KAFKA-17081 Tweak GroupCoordinatorConfig: re-introduce local attributes and validation (#16524)
add e2ec389a7c6 KAFKA-15838: KIP-1040: Add replace.null.with.default to InsertField, ExtractField, HeaderFrom, Cast, SetSchemaMetadata, TimestampConverter, MaskField transforms (#15756)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/connect/transforms/Cast.java | 19 +++-
.../kafka/connect/transforms/ExtractField.java | 26 +++--
.../kafka/connect/transforms/HeaderFrom.java | 19 +++-
.../kafka/connect/transforms/InsertField.java | 16 +++-
.../apache/kafka/connect/transforms/MaskField.java | 16 +++-
.../connect/transforms/SetSchemaMetadata.java | 18 +++-
.../connect/transforms/TimestampConverter.java | 21 ++++-
.../connect/transforms/field/SingleFieldPath.java | 10 +-
.../apache/kafka/connect/transforms/CastTest.java | 27 ++++++
.../kafka/connect/transforms/ExtractFieldTest.java | 105 ++++++++++++++++-----
.../kafka/connect/transforms/HeaderFromTest.java | 63 +++++++++----
.../kafka/connect/transforms/InsertFieldTest.java | 42 +++++++++
.../kafka/connect/transforms/MaskFieldTest.java | 4 +
.../connect/transforms/SetSchemaMetadataTest.java | 55 +++++++++--
.../connect/transforms/TimestampConverterTest.java | 40 ++++++++
15 files changed, 409 insertions(+), 72 deletions(-)