Class SinkRecord

Namespace: Org.Apache.Kafka.Connect.Sink

Assembly: MASES.KNet.dll

https://www.javadoc.io/doc/org.apache.kafka/connect-api/3.9.0/org/apache/kafka/connect/sink/SinkRecord.html

public class SinkRecord : ConnectRecord<SinkRecord>, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition

Inheritance: object

DynamicObject

JVMBridgeBase

JVMBridgeBase<ConnectRecord<SinkRecord>>

ConnectRecord<SinkRecord>

SinkRecord

Implements: IDynamicMetaObjectProvider

IJVMBridgeCore

IDisposable

IJVMBridgeBaseStatic

IJVMBridgeBase

IJVMBridgeDefinition

Inherited Members: ConnectRecord<SinkRecord>.DateTime

ConnectRecord<SinkRecord>.NewRecord(String, Integer, Schema, object, Schema, object, Long, Iterable<Header>)

ConnectRecord<SinkRecord>.NewRecord(String, Integer, Schema, object, Schema, object, Long)

ConnectRecord<SinkRecord>.KafkaPartition()

ConnectRecord<SinkRecord>.Timestamp()

ConnectRecord<SinkRecord>.Key()

ConnectRecord<SinkRecord>.Value()

ConnectRecord<SinkRecord>.Topic()

ConnectRecord<SinkRecord>.KeySchema()

ConnectRecord<SinkRecord>.ValueSchema()

ConnectRecord<SinkRecord>.Headers()

JVMBridgeBase<ConnectRecord<SinkRecord>>.SExecute(IJavaType, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.SExecuteWithSignature(IJavaType, string, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.SExecute(string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.SExecuteWithSignature(string, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.SExecute<TReturn>(IJavaType, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.SExecuteWithSignature<TReturn>(IJavaType, string, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.SExecute<TReturn>(string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.SExecuteWithSignature<TReturn>(string, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.SExecute(Type, IJavaType, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.SExecuteWithSignature(Type, IJavaType, string, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.SExecute(Type, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.SExecuteWithSignature(Type, string, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.SExecute<TNewClass, TReturn>(IJavaType, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.SExecuteWithSignature<TNewClass, TReturn>(IJavaType, string, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.SExecute<TNewClass, TReturn>(string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.SExecuteWithSignature<TNewClass, TReturn>(string, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.SExecute<TReturn>(Type, IJavaType, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.SExecuteWithSignature<TReturn>(Type, IJavaType, string, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.SExecute<TReturn>(Type, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.SExecuteWithSignature<TReturn>(Type, string, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.SExecute<TNewClass, TReturn, TConverter>(IJavaType, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.SExecuteWithSignature<TNewClass, TReturn, TConverter>(IJavaType, string, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.SExecute<TNewClass, TReturn, TConverter>(string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.SExecuteWithSignature<TNewClass, TReturn, TConverter>(string, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.SExecute<TReturn, TConverter>(Type, IJavaType, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.SExecuteWithSignature<TReturn, TConverter>(Type, IJavaType, string, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.SExecute<TReturn, TConverter>(Type, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.SExecuteWithSignature<TReturn, TConverter>(Type, string, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.SExecuteArray<T>(IJavaType, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.SExecuteWithSignatureArray<T>(IJavaType, string, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.SExecuteArray<T>(string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.SExecuteWithSignatureArray<T>(string, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.SGetField(IJavaType, string)

JVMBridgeBase<ConnectRecord<SinkRecord>>.SGetField(string)

JVMBridgeBase<ConnectRecord<SinkRecord>>.SGetField<TReturn>(IJavaType, string)

JVMBridgeBase<ConnectRecord<SinkRecord>>.SGetField<TReturn>(string)

JVMBridgeBase<ConnectRecord<SinkRecord>>.SGetFieldArray<TReturn>(IJavaType, string)

JVMBridgeBase<ConnectRecord<SinkRecord>>.SGetFieldArray<TReturn>(string)

JVMBridgeBase<ConnectRecord<SinkRecord>>.SSetField(IJavaType, string, object)

JVMBridgeBase<ConnectRecord<SinkRecord>>.SSetField(string, object)

JVMBridgeBase<ConnectRecord<SinkRecord>>.SSetField<TValue>(IJavaType, string, TValue)

JVMBridgeBase<ConnectRecord<SinkRecord>>.SSetField<TValue>(string, TValue)

JVMBridgeBase<ConnectRecord<SinkRecord>>.IsAssignableFrom(string)

JVMBridgeBase<ConnectRecord<SinkRecord>>.IsAssignableFrom(IJavaType)

JVMBridgeBase<ConnectRecord<SinkRecord>>.IsAssignableFrom<T>()

JVMBridgeBase<ConnectRecord<SinkRecord>>.New(params object[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.NewWithSignature(string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.Execute<T>(params T[])

JVMBridgeBase<ConnectRecord<SinkRecord>>.DynBridgeClazz

JVMBridgeBase<ConnectRecord<SinkRecord>>.BridgeClazz

JVMBridgeBase.ClazzOf<TClass>(bool)

JVMBridgeBase.ClazzOf(string, bool)

JVMBridgeBase.RuntimeClassNameOf<T>()

JVMBridgeBase.ClassNameOf<T>()

JVMBridgeBase.ClassOf<T>()

JVMBridgeBase.WrapsDirect<TNewClass>(IJavaObject)

JVMBridgeBase.Wraps<TNewClass>(IJavaObject)

JVMBridgeBase.Wraps(Type, IJavaObject, string)

JVMBridgeBase.Wraps<TNewClass, TReturn>(IJavaObject)

JVMBridgeBase.Wraps<TReturn>(Type, IJavaObject, string)

JVMBridgeBase.Wraps<TNewClass, TReturn, TConverter>(IJavaObject)

JVMBridgeBase.Wraps<TReturn, TConverter>(Type, IJavaObject)

JVMBridgeBase.MonitorEnter()

JVMBridgeBase.MonitorExit()

JVMBridgeBase.IsInstanceOf(string)

JVMBridgeBase.IsInstanceOf(IJavaType)

JVMBridgeBase.IsInstanceOf<T>()

JVMBridgeBase.RuntimeIsInstanceOf<T>()

JVMBridgeBase.CastTo<TNewClass>()

JVMBridgeBase.CastDirect<TNewClass>()

JVMBridgeBase.Dispose()

JVMBridgeBase.ToString()

JVMBridgeBase.Equals(object)

JVMBridgeBase.GetHashCode()

JVMBridgeBase.Notify()

JVMBridgeBase.NotifyAll()

JVMBridgeBase.Wait()

JVMBridgeBase.Wait(long)

JVMBridgeBase.Wait(long, int)

JVMBridgeBase.IExecute(string, params object[])

JVMBridgeBase.IExecuteWithSignature(string, string, params object[])

JVMBridgeBase.IExecute<TReturn>(string, params object[])

JVMBridgeBase.IExecuteWithSignature<TReturn>(string, string, params object[])

JVMBridgeBase.IExecute<TNewClass, TReturn>(string, params object[])

JVMBridgeBase.IExecuteWithSignature<TNewClass, TReturn>(string, string, params object[])

JVMBridgeBase.IExecute<TNewClass, TReturn, TConverter>(string, params object[])

JVMBridgeBase.IExecuteWithSignature<TNewClass, TReturn, TConverter>(string, string, params object[])

JVMBridgeBase.IExecuteArray<T>(string, params object[])

JVMBridgeBase.IExecuteWithSignatureArray<T>(string, string, params object[])

JVMBridgeBase.IGetField(string)

JVMBridgeBase.IGetField<TReturn>(string)

JVMBridgeBase.IGetFieldArray<TReturn>(string)

JVMBridgeBase.ISetField(string, object)

JVMBridgeBase.ISetField<TValue>(string, TValue)

JVMBridgeBase.DynBridgeInstance

JVMBridgeBase.BridgeInstance

JVMBridgeBase.IsBridgeListener

DynamicObject.TryGetMember(GetMemberBinder, out object)

DynamicObject.TrySetMember(SetMemberBinder, object)

DynamicObject.TryDeleteMember(DeleteMemberBinder)

DynamicObject.TryInvokeMember(InvokeMemberBinder, object[], out object)

DynamicObject.TryConvert(ConvertBinder, out object)

DynamicObject.TryCreateInstance(CreateInstanceBinder, object[], out object)

DynamicObject.TryInvoke(InvokeBinder, object[], out object)

DynamicObject.TryBinaryOperation(BinaryOperationBinder, object, out object)

DynamicObject.TryUnaryOperation(UnaryOperationBinder, out object)

DynamicObject.TryGetIndex(GetIndexBinder, object[], out object)

DynamicObject.TrySetIndex(SetIndexBinder, object[], object)

DynamicObject.TryDeleteIndex(DeleteIndexBinder, object[])

DynamicObject.GetDynamicMemberNames()

DynamicObject.GetMetaObject(Expression)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetType()

object.MemberwiseClone()

Constructors

SinkRecord()

Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge

public SinkRecord()

SinkRecord(String, int, Schema, object, Schema, object, long)

https://www.javadoc.io/doc/org.apache.kafka/connect-api/3.9.0/org/apache/kafka/connect/sink/SinkRecord.html#org.apache.kafka.connect.sink.SinkRecord(java.lang.String,int,org.apache.kafka.connect.data.Schema,java.lang.Object,org.apache.kafka.connect.data.Schema,java.lang.Object,long)

public SinkRecord(String arg0, int arg1, Schema arg2, object arg3, Schema arg4, object arg5, long arg6)

Parameters

arg0 String: String
arg1 int: int
arg2 Schema: Schema
arg3 object: object
arg4 Schema: Schema
arg5 object: object
arg6 long: long

SinkRecord(String, int, Schema, object, Schema, object, long, Long, TimestampType)

public SinkRecord(String arg0, int arg1, Schema arg2, object arg3, Schema arg4, object arg5, long arg6, Long arg7, TimestampType arg8)

Parameters

arg0 String: String
arg1 int: int
arg2 Schema: Schema
arg3 object: object
arg4 Schema: Schema
arg5 object: object
arg6 long: long
arg7 Long: Long
arg8 TimestampType: TimestampType

SinkRecord(String, int, Schema, object, Schema, object, long, Long, TimestampType, Iterable<Header>)

public SinkRecord(String arg0, int arg1, Schema arg2, object arg3, Schema arg4, object arg5, long arg6, Long arg7, TimestampType arg8, Iterable<Header> arg9)

Parameters

arg0 String: String
arg1 int: int
arg2 Schema: Schema
arg3 object: object
arg4 Schema: Schema
arg5 object: object
arg6 long: long
arg7 Long: Long
arg8 TimestampType: TimestampType
arg9 Iterable<Header>: Iterable

SinkRecord(String, int, Schema, object, Schema, object, long, Long, TimestampType, Iterable<Header>, String, Integer, long)

public SinkRecord(String arg0, int arg1, Schema arg2, object arg3, Schema arg4, object arg5, long arg6, Long arg7, TimestampType arg8, Iterable<Header> arg9, String arg10, Integer arg11, long arg12)

Parameters

arg0 String: String
arg1 int: int
arg2 Schema: Schema
arg3 object: object
arg4 Schema: Schema
arg5 object: object
arg6 long: long
arg7 Long: Long
arg8 TimestampType: TimestampType
arg9 Iterable<Header>: Iterable
arg10 String: String
arg11 Integer: Integer
arg12 long: long

SinkRecord(params object[])

Generic constructor: it is useful for JCOBridge when there is a derived class which needs to pass arguments to the highest JVMBridgeBase class

public SinkRecord(params object[] args)

Parameters

args object[]

Properties

BridgeClassName

https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_BridgeClassName.htm

public override string BridgeClassName { get; }

Property Value

string

IsBridgeAbstract

https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_IsBridgeAbstract.htm

public override bool IsBridgeAbstract { get; }

Property Value

bool

IsBridgeCloseable

https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_IsBridgeCloseable.htm

public override bool IsBridgeCloseable { get; }

Property Value

bool

IsBridgeInterface

https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_IsBridgeInterface.htm

public override bool IsBridgeInterface { get; }

Property Value

bool

IsBridgeStatic

https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_IsBridgeStatic.htm

public override bool IsBridgeStatic { get; }

Property Value

bool

Methods

KafkaOffset()

https://www.javadoc.io/doc/org.apache.kafka/connect-api/3.9.0/org/apache/kafka/connect/sink/SinkRecord.html#kafkaOffset--

public long KafkaOffset()

Returns

long: long

OriginalKafkaOffset()

https://www.javadoc.io/doc/org.apache.kafka/connect-api/3.9.0/org/apache/kafka/connect/sink/SinkRecord.html#originalKafkaOffset--

public long OriginalKafkaOffset()

Returns

long: long

OriginalKafkaPartition()

https://www.javadoc.io/doc/org.apache.kafka/connect-api/3.9.0/org/apache/kafka/connect/sink/SinkRecord.html#originalKafkaPartition--

public Integer OriginalKafkaPartition()

Returns

Integer: Integer

OriginalTopic()

https://www.javadoc.io/doc/org.apache.kafka/connect-api/3.9.0/org/apache/kafka/connect/sink/SinkRecord.html#originalTopic--

public String OriginalTopic()

Returns

String: String

TimestampType()

https://www.javadoc.io/doc/org.apache.kafka/connect-api/3.9.0/org/apache/kafka/connect/sink/SinkRecord.html#timestampType--

public TimestampType TimestampType()

Returns

TimestampType: TimestampType

Table of Contents

Class SinkRecord

Constructors

SinkRecord()

SinkRecord(String, int, Schema, object, Schema, object, long)

Parameters

SinkRecord(String, int, Schema, object, Schema, object, long, Long, TimestampType)

Parameters

SinkRecord(String, int, Schema, object, Schema, object, long, Long, TimestampType, Iterable<Header>)

Parameters

SinkRecord(String, int, Schema, object, Schema, object, long, Long, TimestampType, Iterable<Header>, String, Integer, long)

Parameters

SinkRecord(params object[])

Parameters

Properties

BridgeClassName

Property Value

IsBridgeAbstract

Property Value

IsBridgeCloseable

Property Value

IsBridgeInterface

Property Value

IsBridgeStatic

Property Value

Methods

KafkaOffset()

Returns

OriginalKafkaOffset()

Returns

OriginalKafkaPartition()

Returns

OriginalTopic()

Returns

TimestampType()

Returns