Class ConnectRecord<R, TKey, TValue>

Namespace

Org.Apache.Kafka.Connect.Connector

Assembly

MASES.KNet.dll

KNet helper for ConnectRecord

public class ConnectRecord<R, TKey, TValue> : JVMBridgeBase<ConnectRecord<R, TKey, TValue>>, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition where R : ConnectRecord<R, TKey, TValue>

Type Parameters

R

The class extending ConnectRecord<R, TKey, TValue>

TKey

The type of the key to be inserted in Kafka

TValue

The type of value to be inserted in Kafka

Inheritance

object

DynamicObject

JVMBridgeBase

JVMBridgeBase<ConnectRecord<R, TKey, TValue>>

ConnectRecord<R, TKey, TValue>

Implements

IDynamicMetaObjectProvider

IJVMBridgeCore

IDisposable

IJVMBridgeBaseStatic

IJVMBridgeBase

IJVMBridgeDefinition

Derived

SinkRecord<TKey, TValue>

SourceRecord<TKeySource, TOffset, TKey, TValue>

Inherited Members

JVMBridgeBase<ConnectRecord<R, TKey, TValue>>.SExecute(IJavaType, string, params object[])

JVMBridgeBase<ConnectRecord<R, TKey, TValue>>.SExecuteWithSignature(IJavaType, string, string, params object[])

JVMBridgeBase<ConnectRecord<R, TKey, TValue>>.SExecute(string, params object[])

JVMBridgeBase<ConnectRecord<R, TKey, TValue>>.SExecuteWithSignature(string, string, params object[])

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

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

JVMBridgeBase<ConnectRecord<R, TKey, TValue>>.SExecute<TReturn>(string, params object[])

JVMBridgeBase<ConnectRecord<R, TKey, TValue>>.SExecuteWithSignature<TReturn>(string, string, params object[])

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

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

JVMBridgeBase<ConnectRecord<R, TKey, TValue>>.SExecute(Type, string, params object[])

JVMBridgeBase<ConnectRecord<R, TKey, TValue>>.SExecuteWithSignature(Type, string, string, params object[])

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

JVMBridgeBase<ConnectRecord<R, TKey, TValue>>.SExecuteArray<T>(string, params object[])

JVMBridgeBase<ConnectRecord<R, TKey, TValue>>.SExecuteWithSignatureArray<T>(string, string, params object[])

JVMBridgeBase<ConnectRecord<R, TKey, TValue>>.SGetField(IJavaType, string)

JVMBridgeBase<ConnectRecord<R, TKey, TValue>>.SGetField(string)

JVMBridgeBase<ConnectRecord<R, TKey, TValue>>.SGetField<TReturn>(IJavaType, string)

JVMBridgeBase<ConnectRecord<R, TKey, TValue>>.SGetField<TReturn>(string)

JVMBridgeBase<ConnectRecord<R, TKey, TValue>>.SGetFieldArray<TReturn>(IJavaType, string)

JVMBridgeBase<ConnectRecord<R, TKey, TValue>>.SGetFieldArray<TReturn>(string)

JVMBridgeBase<ConnectRecord<R, TKey, TValue>>.SSetField(IJavaType, string, object)

JVMBridgeBase<ConnectRecord<R, TKey, TValue>>.SSetField(string, object)

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

JVMBridgeBase<ConnectRecord<R, TKey, TValue>>.SSetField<TValue>(string, TValue)

JVMBridgeBase<ConnectRecord<R, TKey, TValue>>.IsAssignableFrom(string)

JVMBridgeBase<ConnectRecord<R, TKey, TValue>>.IsAssignableFrom(IJavaType)

JVMBridgeBase<ConnectRecord<R, TKey, TValue>>.IsAssignableFrom<T>()

JVMBridgeBase<ConnectRecord<R, TKey, TValue>>.New(params object[])

JVMBridgeBase<ConnectRecord<R, TKey, TValue>>.NewWithSignature(string, params object[])

JVMBridgeBase<ConnectRecord<R, TKey, TValue>>.Execute<T>(params T[])

JVMBridgeBase<ConnectRecord<R, TKey, TValue>>.DynBridgeClazz

JVMBridgeBase<ConnectRecord<R, TKey, TValue>>.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.IsBridgeInterface

JVMBridgeBase.IsBridgeStatic

JVMBridgeBase.IsBridgeCloseable

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

ConnectRecord()

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

public ConnectRecord()

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

protected ConnectRecord(params object[] args)

Parameters

args object[]

ConnectRecord(string, int, Schema, TKey, Schema, TValue, DateTime)

https://www.javadoc.io/doc/org.apache.kafka/connect-api/3.5.0/org/apache/kafka/connect/connector/ConnectRecord.html#org.apache.kafka.connect.connector.ConnectRecord(java.lang.String,java.lang.Integer,org.apache.kafka.connect.data.Schema,java.lang.Object,org.apache.kafka.connect.data.Schema,java.lang.Object,java.lang.Long)

public ConnectRecord(string topic, int kafkaPartition, Schema keySchema, TKey key, Schema valueSchema, TValue value, DateTime timestamp)

Parameters

topic string

kafkaPartition int

keySchema Schema

key TKey

valueSchema Schema

value TValue

timestamp DateTime

ConnectRecord(string, int, Schema, TKey, Schema, TValue, DateTime, Headers)

https://www.javadoc.io/doc/org.apache.kafka/connect-api/3.5.0/org/apache/kafka/connect/connector/ConnectRecord.html#org.apache.kafka.connect.connector.ConnectRecord(java.lang.String,java.lang.Integer,org.apache.kafka.connect.data.Schema,java.lang.Object,org.apache.kafka.connect.data.Schema,java.lang.Object,java.lang.Long,java.lang.Iterable)

public ConnectRecord(string topic, int kafkaPartition, Schema keySchema, TKey key, Schema valueSchema, TValue value, DateTime timestamp, Headers headers)

Parameters

topic string

kafkaPartition int

keySchema Schema

key TKey

valueSchema Schema

value TValue

timestamp DateTime

headers Headers

Properties

BridgeClassName

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

public override string BridgeClassName { get; }

Property Value

string

Headers

The Headers

public Headers Headers { get; }

Property Value

Headers

IsBridgeAbstract

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

public override bool IsBridgeAbstract { get; }

Property Value

bool

KafkaPartition

Partition

public int KafkaPartition { get; }

Property Value

int

Key

Key

public TKey Key { get; }

Property Value

TKey

KeySchema

KeySchema

public Schema KeySchema { get; }

Property Value

Schema

Timestamp

Timestamp

public DateTime Timestamp { get; }

Property Value

DateTime

Topic

Topic

public string Topic { get; }

Property Value

string

Value

Value

public TValue Value { get; }

Property Value

TValue

ValueSchema

ValueSchema

public Schema ValueSchema { get; }

Property Value

Schema

Methods

NewRecord(string, int, Schema, TKey, Schema, TValue, DateTime)

https://www.javadoc.io/doc/org.apache.kafka/connect-api/3.5.0/org/apache/kafka/connect/connector/ConnectRecord.html#newRecord-java.lang.String-java.lang.Integer-org.apache.kafka.connect.data.Schema-java.lang.Object-org.apache.kafka.connect.data.Schema-java.lang.Object-java.lang.Long-

public R NewRecord(string topic, int kafkaPartition, Schema keySchema, TKey key, Schema valueSchema, TValue value, DateTime timestamp)

Parameters

topic string

kafkaPartition int

keySchema Schema

key TKey

valueSchema Schema

value TValue

timestamp DateTime

Returns

R

NewRecord(string, int, Schema, TKey, Schema, TValue, DateTime, Headers)

https://www.javadoc.io/doc/org.apache.kafka/connect-api/3.5.0/org/apache/kafka/connect/connector/ConnectRecord.html#newRecord-java.lang.String-java.lang.Integer-org.apache.kafka.connect.data.Schema-java.lang.Object-org.apache.kafka.connect.data.Schema-java.lang.Object-java.lang.Long-java.lang.Iterable-

public R NewRecord(string topic, int kafkaPartition, Schema keySchema, TKey key, Schema valueSchema, TValue value, DateTime timestamp, Headers headers)

Parameters

topic string

kafkaPartition int

keySchema Schema

key TKey

valueSchema Schema

value TValue

timestamp DateTime

headers Headers

Returns

R