Class KNetSinkTask<TTask>

An implementation of KNetTask<TTask> for sink task

public abstract class KNetSinkTask<TTask> : KNetTask<TTask>, IKNetTask, ITask, IKNetConnectLogging where TTask : KNetSinkTask<TTask>

Inherited Members: KNetTask<TTask>.Version()

KNetTask.ExecuteOnTask(string, params object[])

KNetTask.ExecuteOnTask<T>(string, params object[])

KNetTask.DataToExchange<T>()

KNetTask.DataToExchange(object)

KNetTask.Context<T>()

KNetTask.Properties

KNetTask.Connector

KNetTask.TaskId

KNetTask.StartInternal()

KNetTask.Start(Map<String, String>)

KNetTask.Start(IReadOnlyDictionary<string, string>)

KNetTask.StopInternal()

KNetTask.Stop()

KNetTask.VersionInternal()

KNetTask.IsTraceEnabled

KNetTask.IsDebugEnabled

KNetTask.IsInfoEnabled

KNetTask.IsWarnEnabled

KNetTask.IsErrorEnabled

KNetTask.LogTrace(string)

KNetTask.LogTrace(string, JVMBridgeException)

KNetTask.LogDebug(string)

KNetTask.LogDebug(string, JVMBridgeException)

KNetTask.LogInfo(string)

KNetTask.LogInfo(string, JVMBridgeException)

KNetTask.LogWarn(string)

KNetTask.LogWarn(string, JVMBridgeException)

KNetTask.LogError(string)

KNetTask.LogError(string, JVMBridgeException)

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

Properties

public SinkTaskContext Context { get; }

Set the ReflectedTaskClassName of the connector to a fixed value

public override string ReflectedTaskClassName { get; }

Implement the method to execute the Put action

public abstract void Put(IEnumerable<SinkRecord> collection)

collection IEnumerable<SinkRecord>: The set of SinkRecord from Apache Kafka Connect framework

Public method used from Java to trigger Put(IEnumerable<SinkRecord>)

public void PutInternal()