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()

Properties

Properties

The properties retrieved from Configure(Map<String, object>)

IReadOnlyDictionary<string, object> Properties { get; }

Property Value

IReadOnlyDictionary<string, object>

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(IReadOnlyDictionary<string, object>)

Implement the method to execute the start action

void Configure(IReadOnlyDictionary<string, object> props)

Parameters

props IReadOnlyDictionary<string, object>

The set of properties returned from Apache Kafka Connect framework: the IReadOnlyDictionary<TKey, TValue> contains the same info from configuration file.