kafka-connect-transformers

License	Apache License 2.0
Categories	Data ORM
GroupId	com.datamountaineer
ArtifactId	kafka-connect-transformers
Last Version	1.0.0
Release Date	Feb 6, 2018
Type	jar
Description	kafka-connect-transformers kafka-connect-transformers
Project URL	https://github.com/landoop/kafka-connect-transformers
Source Code Management	https://github.com/landoop/kafka-connect-transformers.git

Download kafka-connect-transformers

Filename	Size
kafka-connect-transformers-1.0.0.pom
kafka-connect-transformers-1.0.0.jar	39 KB
kafka-connect-transformers-1.0.0-sources.jar	5 KB
kafka-connect-transformers-1.0.0-scaladoc.jar	389 KB
kafka-connect-transformers-1.0.0-javadoc.jar	261 bytes

How to add to project

Apache Maven

<!-- https://jarcasting.com/artifacts/com.datamountaineer/kafka-connect-transformers/ -->
<dependency>
    <groupId>com.datamountaineer</groupId>
    <artifactId>kafka-connect-transformers</artifactId>
    <version>1.0.0</version>
</dependency>

Gradle Groovy

// https://jarcasting.com/artifacts/com.datamountaineer/kafka-connect-transformers/
implementation 'com.datamountaineer:kafka-connect-transformers:1.0.0'

Gradle Kotlin

// https://jarcasting.com/artifacts/com.datamountaineer/kafka-connect-transformers/
implementation ("com.datamountaineer:kafka-connect-transformers:1.0.0")

Apache Buildr

'com.datamountaineer:kafka-connect-transformers:jar:1.0.0'

Apache Ivy

<dependency org="com.datamountaineer" name="kafka-connect-transformers" rev="1.0.0">
  <artifact name="kafka-connect-transformers" type="jar" />
</dependency>

Groovy Grape

@Grapes(
@Grab(group='com.datamountaineer', module='kafka-connect-transformers', version='1.0.0')
)

Scala SBT

libraryDependencies += "com.datamountaineer" % "kafka-connect-transformers" % "1.0.0"

Leiningen

[com.datamountaineer/kafka-connect-transformers "1.0.0"]

Dependencies

test (7)

Group / Artifact	Type	Version
org.mockito : mockito-all	jar	1.10.19
org.scalacheck : scalacheck_2.11	jar	1.11.1
org.scalatest : scalatest_2.11	jar	2.2.6
junit : junit	jar	4.11
org.apache.curator : curator-test	jar	3.1.0
org.powermock : powermock-module-junit4	jar	1.6.5
org.pegdown : pegdown	jar	1.1.0

Project Modules

There are no modules declared in this project.

kafka-connect-transformers

Transformations

• LogicalFieldToString - Format logical fields value
• MapKeyToString - Replace map key to string value
• NestingFields - Create nesting fields from value to new field

LogicalFieldToString

com.datamountaineer.streamreactor.connect.transforms.LogicalFieldToString

Use the concrete transformation type designed for the record key (com.datamountaineer.streamreactor.connect.transforms.LogicalFieldToString$Key) or value (com.datamountaineer.streamreactor.connect.transforms.LogicalFieldToString$Value).

NAME	DESCRIPTION	TYPE	DEFAULT	VALID VALUES	IMPORTANCE
fields	Field names to be formatted.	list		non-empty list	high
format	Format to apply.	string		valid DecimalFormat, DateFormat format	high

MapKeyToString

com.datamountaineer.streamreactor.connect.transforms.MapKeyToString

Use the concrete transformation type designed for the record key (com.datamountaineer.streamreactor.connect.transforms.MapKeyToString$Key) or value (com.datamountaineer.streamreactor.connect.transforms.MapKeyToString$Value).

NAME	DESCRIPTION	TYPE	DEFAULT	VALID VALUES	IMPORTANCE
fields	Field names to be cast.	list		non-empty list	high

NestingFields

com.datamountaineer.streamreactor.connect.transforms.NestingFields

Use the concrete transformation type designed for the record key (com.datamountaineer.streamreactor.connect.transforms.NestingFields$Key) or value (com.datamountaineer.streamreactor.connect.transforms.NestingFields$Value).

NAME	DESCRIPTION	TYPE	DEFAULT	VALID VALUES	IMPORTANCE
fields	Field names to add in the nested field.	list		non-empty list	high
nested.name	Nested field name.	string		non-empty string	high

Lenses.io

Please visit https://github.com/lensesio for Lenses.io's repositories

Versions

Version
1.0.0 Feb 6, 2018