Table of Contents

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<IJVMBridgeBaseInstance>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeBaseInstance, 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
JVMBridgeBase<ConnectRecord<R, TKey, TValue>>
ConnectRecord<R, TKey, TValue>
Implements
Derived

Constructors

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(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 Integer KafkaPartition { get; }

Property Value

Integer

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.2.1/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.2.1/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
Edit this page