org.apache.beam.io.debezium

Class SourceRecordJson

java.lang.Object

org.apache.beam.io.debezium.SourceRecordJson

public class SourceRecordJson
extends java.lang.Object

This class can be used as a mapper for each SourceRecord retrieved.

What it does

It maps any SourceRecord retrieved from any supported io.debezium.connector to JSON

How it works

It will extract valuable fields from any given SourceRecord:

• before - loadBefore()
• after - loadAfter()
• metadata - loadMetadata()
  • schema - Database Schema
  • connector - Connector used
  • version - Connector version

Usage Example

Map each SourceRecord to JSON

     DebeziumIO.read()
         .withFormatFunction(new SourceRecordJson.SourceRecordJsonMapper()
 

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SourceRecordJson.SourceRecordJsonMapper SourceRecordJson implementation.

Constructor Summary

Constructors

Constructor and Description
SourceRecordJson(@Nullable org.apache.kafka.connect.source.SourceRecord sourceRecord) Initializer.

Method Summary

Modifier and Type	Method and Description
java.lang.String	toJson() Transforms the extracted data to a JSON string.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SourceRecordJson

public SourceRecordJson(@Nullable org.apache.kafka.connect.source.SourceRecord sourceRecord)

Initializer.

Parameters:

sourceRecord - retrieved SourceRecord using a supported SourceConnector

Method Detail

toJson

public java.lang.String toJson()

Transforms the extracted data to a JSON string.

Returns:

JSON String