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, IEquatable<IJVMBridgeBase>, 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

IEquatable<IJVMBridgeBase>

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<TArrayType>(IJavaType, string, params object[])

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

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

JVMBridgeBase<ConnectRecord<R, TKey, TValue>>.SExecuteWithSignatureArray<TArrayType>(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>>.NewAndWrapsDirect<TNewClass>(string, params object[])

JVMBridgeBase<ConnectRecord<R, TKey, TValue>>.NewWithSignatureAndWrapsDirect<TNewClass>(string, 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.ReferenceEqualsJVM(JVMBridgeBase, JVMBridgeBase)

JVMBridgeBase.ClazzOf<TClass>(bool)

JVMBridgeBase.ClazzOf<TClass>(out Exception, bool)

JVMBridgeBase.ClazzOf(string, bool)

JVMBridgeBase.ClazzOf(string, out Exception, bool)

JVMBridgeBase.RuntimeClassNameOf<T>()

JVMBridgeBase.RuntimeClassNameOf(Type)

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.Dispose(bool)

JVMBridgeBase.ToString()

JVMBridgeBase.Equals(IJVMBridgeBase)

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<TArrayType>(string, params object[])

JVMBridgeBase.IExecuteWithSignatureArray<TArrayType>(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(IJVMBridgeBaseInitializer)

Internal constructor: used internally from JCOBridge

[Obsolete("This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public ConnectRecord(IJVMBridgeBaseInitializer initializer)

Parameters

initializer IJVMBridgeBaseInitializer

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/latest/org/apache/kafka/connect/connector/ConnectRecord.html#%3Cinit%3E(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/latest/org/apache/kafka/connect/connector/ConnectRecord.html#%3Cinit%3E(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

Java class name to be instantiated

public override string BridgeClassName { get; }

Property Value

string

Headers

The Headers

public Headers Headers { get; }

Property Value

Headers

IsBridgeAbstract

true if the BridgeClassName is an abstract class, i.e. cannot be created an instance

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/4.1.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/4.1.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