JarCasting
JarCasting JarCasting

kafka-connect-transformers


License

License
Categories

Categories

Data ORM
GroupId

GroupId

com.datamountaineer
ArtifactId

ArtifactId

kafka-connect-transformers
Last Version

Last Version

1.0.0
Release Date

Release Date
Type

Type

jar
Description

Description

kafka-connect-transformers
kafka-connect-transformers
Project URL

Project URL

https://github.com/landoop/kafka-connect-transformers
Source Code Management

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
Browse

How to add to project

<!-- 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>
// https://jarcasting.com/artifacts/com.datamountaineer/kafka-connect-transformers/
implementation 'com.datamountaineer:kafka-connect-transformers:1.0.0'
// https://jarcasting.com/artifacts/com.datamountaineer/kafka-connect-transformers/
implementation ("com.datamountaineer:kafka-connect-transformers:1.0.0")
'com.datamountaineer:kafka-connect-transformers:jar:1.0.0'
<dependency org="com.datamountaineer" name="kafka-connect-transformers" rev="1.0.0">
  <artifact name="kafka-connect-transformers" type="jar" />
</dependency>
@Grapes(
@Grab(group='com.datamountaineer', module='kafka-connect-transformers', version='1.0.0')
)
libraryDependencies += "com.datamountaineer" % "kafka-connect-transformers" % "1.0.0"
[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
com.datamountaineer

Lenses.io

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

Versions

Version
1.0.0