Interface ITransformation

Namespace

MASES.KNet.Connect.Transforms

Assembly

MASES.KNet.dll

.NET interface for Transformation

public interface ITransformation : IVersion

Inherited Members

IVersion.Version()

Methods

Apply(ConnectRecord)

https://www.javadoc.io/doc/org.apache.kafka/connect-api/4.1.1/org/apache/kafka/connect/transforms/Transformation.html#apply(org.apache.kafka.connect.connector.ConnectRecord)

ConnectRecord Apply(ConnectRecord record)

Parameters

record ConnectRecord

Returns

ConnectRecord

ConnectRecord

Close()

https://www.javadoc.io/doc/org.apache.kafka/connect-api/4.1.1/org/apache/kafka/connect/transforms/Transformation.html#close()

void Close()

Config()

https://www.javadoc.io/doc/org.apache.kafka/connect-api/4.1.1/org/apache/kafka/connect/transforms/Transformation.html#config()

ConfigDef Config()

Returns

ConfigDef

ConfigDef

Configure(Map<String, object>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.1/org/apache/kafka/common/Configurable.html#configure(java.util.Map)

void Configure(Map<String, object> props)

Parameters

props Map<String, object>