Interface IKNetTransformation

Namespace

MASES.KNet.Connect.Transforms

Assembly

MASES.KNet.dll

Specific implementation of ITransformation to support KNet Connect SDK

public interface IKNetTransformation : ITransformation, IVersion

Inherited Members

ITransformation.Apply(ConnectRecord)

ITransformation.Configure(Map<String, object>)

ITransformation.Close()

ITransformation.Config()

IVersion.Version()

Methods

Apply(SinkRecord)

Implements the behavior of Apply(ConnectRecord) for record

SinkRecord Apply(SinkRecord record)

Parameters

record SinkRecord

The SinkRecord to test

Returns

SinkRecord

Follow specifications of Apply(ConnectRecord)

Remarks

If the method is overridden never invoke the base method othrwise an exception is raised within the JVM.

Apply(SourceRecord)

Implements the behavior of Apply(ConnectRecord) for record

SourceRecord Apply(SourceRecord record)

Parameters

record SourceRecord

The SourceRecord to test

Returns

SourceRecord

Follow specifications of Apply(ConnectRecord)

Remarks

If the method is overridden never invoke the base method othrwise an exception is raised within the JVM.

Configure(IKNetConfigurationFromMap)

Implement the method to execute the start action

void Configure(IKNetConfigurationFromMap configuration)

Parameters

configuration IKNetConfigurationFromMap

The IKNetConfigurationFromMap to access the properties returned from Apache Kafka Connect framework: the Properties contains the same info from configuration file.