Class SinkRecord

Namespace: Org.Apache.Kafka.Connect.Sink

Assembly: MASES.KNet.dll

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

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

Inheritance: object

DynamicObject

JVMBridgeBase

JVMBridgeBase<ConnectRecord<SinkRecord>>

ConnectRecord<SinkRecord>

SinkRecord

Implements: IDynamicMetaObjectProvider

IJVMBridgeCore

IEquatable<IJVMBridgeBaseInstance>

IDisposable

IJVMBridgeBaseStatic

IJVMBridgeBase

IJVMBridgeBaseInstance

IJVMBridgeDefinition

Inherited Members: ConnectRecord<SinkRecord>.DateTime

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

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

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

Constructors

SinkRecord(String, int, Schema, object, Schema, 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)

https://www.javadoc.io/doc/org.apache.kafka/connect-api/4.2.1/org/apache/kafka/connect/sink/SinkRecord.html#%3Cinit%3E(java.lang.String,int,org.apache.kafka.connect.data.Schema,java.lang.Object,org.apache.kafka.connect.data.Schema,java.lang.Object,long,java.lang.Long,org.apache.kafka.common.record.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(IJVMBridgeBaseInitializer)

Initializer used internally by JCOBridge. Do not use directly.

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

Parameters

initializer IJVMBridgeBaseInitializer

Properties

BridgeClassName

Java class name to be instantiated

public override string BridgeClassName { get; }

Property Value

string

IsBridgeAbstract

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

public override bool IsBridgeAbstract { get; }

Property Value

bool

IsBridgeCloseable

true if the BridgeClassName implements java.lang.AutoCloseable

public override bool IsBridgeCloseable { get; }

Property Value

bool

IsBridgeInterface

true if the BridgeClassName is an interface, i.e. does not have any public constructor

public override bool IsBridgeInterface { get; }

Property Value

bool

IsBridgeStatic

true if the BridgeClassName is a static class, i.e. does not have any public constructor

public override bool IsBridgeStatic { get; }

Property Value

bool

Methods

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

HPA initializer for SinkRecord(Java.Lang.String arg0, int arg1, Org.Apache.Kafka.Connect.Data.Schema arg2, object arg3, Org.Apache.Kafka.Connect.Data.Schema arg4, object arg5, long arg6)

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

Parameters

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

Returns

SinkRecord

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

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

Parameters

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

Returns

SinkRecord

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

HPA initializer for SinkRecord(Java.Lang.String arg0, int arg1, Org.Apache.Kafka.Connect.Data.Schema arg2, object arg3, Org.Apache.Kafka.Connect.Data.Schema arg4, object arg5, long arg6, Java.Lang.Long arg7, Org.Apache.Kafka.Common.Record.TimestampType arg8, Java.Lang.Iterable%3COrg.Apache.Kafka.Connect.Header.Header%3E arg9)

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

Parameters

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

Returns

SinkRecord

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

public static SinkRecord CreatePoolableInstance(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
arg1 int
arg2 Schema
arg3 object
arg4 Schema
arg5 object
arg6 long
arg7 Long
arg8 TimestampType
arg9 Iterable<Header>
arg10 String
arg11 Integer
arg12 long

Returns

SinkRecord

KafkaOffset()

https://www.javadoc.io/doc/org.apache.kafka/connect-api/4.2.1/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/4.2.1/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/4.2.1/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/4.2.1/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/4.2.1/org/apache/kafka/connect/sink/SinkRecord.html#timestampType()

public TimestampType TimestampType()

Returns

TimestampType: TimestampType

Table of Contents

Class SinkRecord

Constructors

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(IJVMBridgeBaseInitializer)

Parameters

Properties

BridgeClassName

Property Value

IsBridgeAbstract

Property Value

IsBridgeCloseable

Property Value

IsBridgeInterface

Property Value

IsBridgeStatic

Property Value

Methods

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

Parameters

Returns

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

Parameters

Returns

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

Parameters

Returns

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

Parameters

Returns

KafkaOffset()

Returns

OriginalKafkaOffset()

Returns

OriginalKafkaPartition()

Returns

OriginalTopic()

Returns

TimestampType()

Returns