kafka-connect-transform-common

kafka-connect-transform-common copied to clipboard

jcustenborder

It would be cool to have a transformation that handles compression and decompression.

jcustenborder

Add TOC for all transforms

1

It's incredibly hard to navigate the README. This makes it slightly less painless and lets new users landing at the project see all the available transforms.

Aergonus

jcustenborder

Add transformation to retrieve a single element from a list.

1

jcustenborder

jcustenborder

fix: implement processMap with recursion on ChangeCase

2

Currently, `ChangeCase` could not handle Map type input record without schema. So, expands the coverage of this SMT.

okayhooni

fix: implement processMap function to MAP structured data

7

Hi @jcustenborder, Maybe you saw If you are using HeaderToField as transforms and your data struct is Map, the plugin is throwing error like "MAP is unsupported ..." I implemented...

peacecwz

I'm using with changeCase type: `com.github.jcustenborder.kafka.connect.transform.common.ChangeCase$Key` from Kafka Confluent to convert data key from upper case to lowercase. After a while of running, the connector threw exception java.lang.UnsupportedOperationException: STRING is...

datngxtiens

Recently I have use this repo to transform some common nested column to normal column but if the nested column is so deep inside (normal is 3 layers) then it...

thuybt