Interface IKNetPredicate

Namespace

MASES.KNet.Connect.Transforms.Predicates

Assembly

MASES.KNet.dll

Specific implementation of IConnector to support KNet Connect SDK

public interface IKNetPredicate : IPredicate, IVersion

Inherited Members

IPredicate.Test(ConnectRecord)

IPredicate.Configure(Map<String, object>)

IPredicate.Close()

IPredicate.Config()

IPredicate.ToStringPredicate()

IVersion.Version()

Properties

Properties

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

IReadOnlyDictionary<string, object> Properties { get; }

Property Value

IReadOnlyDictionary<string, object>

Methods

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.

Test(SinkRecord)

Implements the behavior of Test(ConnectRecord) for record

bool Test(SinkRecord record)

Parameters

record SinkRecord

The SinkRecord to test

Returns

bool

Follow specifications of Test(ConnectRecord)

Remarks

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

Test(SourceRecord)

Implements the behavior of Test(ConnectRecord) for record

bool Test(SourceRecord record)

Parameters

record SourceRecord

The SourceRecord to test

Returns

bool

Follow specifications of Test(ConnectRecord)

Remarks

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