kafka-connect-transform-common

kafka-connect-transform-common copied to clipboard

Was wondering why there is no `UPPER_HYPHEN' option ? I want to make sure all my topics are lower case so I'm doing: UPPER_UNDERSCORE -> LOWER_UNDERSCORE UPPER_CAMEL -> LOWER_CAMEL but...

miramar-labs

This adds the following options to the TimestampNowField transformer: - add.amount "how many of the chosen ChronoUnits to add on top of the timestamp of the system." - add.chronounit "String...

acemoo

Hello, I'm trying to copy the Header value to the key with the transformation below. ``` transforms: "CreateDocID" transforms.CreateDocID.type: "com.github.jcustenborder.kafka.connect.transform.common.HeaderToField$Key" transforms.CreateDocID.header.mappings: "DocId:STRING" ``` according to the documentation It should work,...

arnitolog

Error when creating sink connector with `BytesToString$Value` transforms

9

I installed the plugin via manual process as written on the docs [here](https://jcustenborder.github.io/kafka-connect-documentation/projects/kafka-connect-transform-common/) and then tried to create the new connector with the following body (note that the importante fields...

moreiravictor

[Enhancement] Add String field parsing transforms

1

Add a transform that parse a string field into other primitive values or into array, such as: `int`, `long`, `float`, `double`, `boolean` (or an `array` of one of these). ##...

yoniwg

Similar to 92, a generic topic upper-caser is needed. This is useful for database-to-database pipelines where the target it oracle: mixed case topics result in mixed-case target tables, which creates...

markteehan

Pattern replace to add a prefix

1

Thanks for this open source project. I am facing an issue whereby some json like messages are having numeric filed names that break the final avrò schemas I would like...

dberardo

Unable to instantiate AdjustPrecisionAndScale: Plugin class must have a no-args constructor, and cannot be a non-static inner class

11

Hi, I am trying to update our connectors and transform packages to resolve security vulnerabilities, so i updated my `cp-kafka-connect-base:7.6.0` and `jcustenborder/kafka-connect-transform-common:0.1.0.58` . But now when i run it i...

aonamrata

confluent-hub install is broken

1

``` $ confluent-hub install --no-prompt jcustenborder/kafka-connect-transform-common:0.1.0.58 Running in a "--no-prompt" mode Implicit acceptance of the license below: Apache License 2.0 https:/github.com/jcustenborder/kafka-connect-transform-common/LICENSE Implicit confirmation of the question: You are about to...

wlaw868

[#111] make plugin compatible with kafka 3.7.1

3

This fixes #111 and is a WIP PR as it needs https://github.com/jcustenborder/connect-utils/pull/214 to be merged first.

marcuslinke