Class KafkaBasedLog<K, V>

Namespace

Org.Apache.Kafka.Connect.Util

Assembly

MASES.KNet.dll

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.2.1/org/apache/kafka/connect/util/KafkaBasedLog.html

public class KafkaBasedLog<K, V> : JVMBridgeBase<KafkaBasedLog<K, V>>, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBaseInstance>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeBaseInstance, IJVMBridgeDefinition

Type Parameters

K

V

Inheritance

object

DynamicObject

JVMBridgeBase

JVMBridgeBase<KafkaBasedLog<K, V>>

KafkaBasedLog<K, V>

Implements

IDynamicMetaObjectProvider

IJVMBridgeCore

IEquatable<IJVMBridgeBaseInstance>

IDisposable

IJVMBridgeBaseStatic

IJVMBridgeBase

IJVMBridgeBaseInstance

IJVMBridgeDefinition

Constructors

KafkaBasedLog(String, Map<String, object>, Map<String, object>, Supplier<TopicAdmin>, Callback<ConsumerRecord<K, V>>, Time, Consumer<TopicAdmin>)

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.2.1/org/apache/kafka/connect/util/KafkaBasedLog.html#%3Cinit%3E(java.lang.String,java.util.Map,java.util.Map,java.util.function.Supplier,org.apache.kafka.connect.util.Callback,org.apache.kafka.common.utils.Time,java.util.function.Consumer)

public KafkaBasedLog(String arg0, Map<String, object> arg1, Map<String, object> arg2, Supplier<TopicAdmin> arg3, Callback<ConsumerRecord<K, V>> arg4, Time arg5, Consumer<TopicAdmin> arg6)

Parameters

arg0 String

String

arg1 Map<String, object>

Map

arg2 Map<String, object>

Map

arg3 Supplier<TopicAdmin>

Supplier

arg4 Callback<ConsumerRecord<K, V>>

Callback

arg5 Time

Time

arg6 Consumer<TopicAdmin>

Consumer

KafkaBasedLog(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 KafkaBasedLog(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, Map<String, object>, Map<String, object>, Supplier<TopicAdmin>, Callback<ConsumerRecord<K, V>>, Time, Consumer<TopicAdmin>)

HPA initializer for KafkaBasedLog(Java.Lang.String arg0, Java.Util.Map%3CJava.Lang.String, object%3E arg1, Java.Util.Map%3CJava.Lang.String, object%3E arg2, Java.Util.Function.Supplier%3COrg.Apache.Kafka.Connect.Util.TopicAdmin%3E arg3, Org.Apache.Kafka.Connect.Util.Callback%3COrg.Apache.Kafka.Clients.Consumer.ConsumerRecord%3CK, V%3E%3E arg4, Org.Apache.Kafka.Common.Utils.Time arg5, Java.Util.Function.Consumer%3COrg.Apache.Kafka.Connect.Util.TopicAdmin%3E arg6)

public static KafkaBasedLog<K, V> CreatePoolableInstance(String arg0, Map<String, object> arg1, Map<String, object> arg2, Supplier<TopicAdmin> arg3, Callback<ConsumerRecord<K, V>> arg4, Time arg5, Consumer<TopicAdmin> arg6)

Parameters

arg0 String

arg1 Map<String, object>

arg2 Map<String, object>

arg3 Supplier<TopicAdmin>

arg4 Callback<ConsumerRecord<K, V>>

arg5 Time

arg6 Consumer<TopicAdmin>

Returns

KafkaBasedLog<K, V>

Flush()

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.2.1/org/apache/kafka/connect/util/KafkaBasedLog.html#flush()

public void Flush()

PartitionCount()

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.2.1/org/apache/kafka/connect/util/KafkaBasedLog.html#partitionCount()

public int PartitionCount()

Returns

int

int

ReadToEnd()

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.2.1/org/apache/kafka/connect/util/KafkaBasedLog.html#readToEnd()

public Future<Void> ReadToEnd()

Returns

Future<Void>

Future

ReadToEnd(Callback<Void>)

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.2.1/org/apache/kafka/connect/util/KafkaBasedLog.html#readToEnd(org.apache.kafka.connect.util.Callback)

public void ReadToEnd(Callback<Void> arg0)

Parameters

arg0 Callback<Void>

Callback

Send(K, V)

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.2.1/org/apache/kafka/connect/util/KafkaBasedLog.html#send(java.lang.Object,java.lang.Object)

public void Send(K arg0, V arg1)

Parameters

arg0 K

K

arg1 V

V

Send(K, V, Callback)

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.2.1/org/apache/kafka/connect/util/KafkaBasedLog.html#send(java.lang.Object,java.lang.Object,org.apache.kafka.clients.producer.Callback)

public void Send(K arg0, V arg1, Callback arg2)

Parameters

arg0 K

K

arg1 V

V

arg2 Callback

Callback

SendWithReceipt(K, V)

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.2.1/org/apache/kafka/connect/util/KafkaBasedLog.html#sendWithReceipt(java.lang.Object,java.lang.Object)

public Future<RecordMetadata> SendWithReceipt(K arg0, V arg1)

Parameters

arg0 K

K

arg1 V

V

Returns

Future<RecordMetadata>

Future

SendWithReceipt(K, V, Callback)

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.2.1/org/apache/kafka/connect/util/KafkaBasedLog.html#sendWithReceipt(java.lang.Object,java.lang.Object,org.apache.kafka.clients.producer.Callback)

public Future<RecordMetadata> SendWithReceipt(K arg0, V arg1, Callback arg2)

Parameters

arg0 K

K

arg1 V

V

arg2 Callback

Callback

Returns

Future<RecordMetadata>

Future

Start()

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.2.1/org/apache/kafka/connect/util/KafkaBasedLog.html#start()

public void Start()

Start(bool)

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.2.1/org/apache/kafka/connect/util/KafkaBasedLog.html#start(boolean)

public void Start(bool arg0)

Parameters

arg0 bool

bool

Stop()

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.2.1/org/apache/kafka/connect/util/KafkaBasedLog.html#stop()

public void Stop()

WithExistingClients(String, Consumer<K, V>, Producer<K, V>, TopicAdmin, Callback<ConsumerRecord<K, V>>, Time, Consumer<TopicAdmin>, Predicate<TopicPartition>)

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.2.1/org/apache/kafka/connect/util/KafkaBasedLog.html#withExistingClients(java.lang.String,org.apache.kafka.clients.consumer.Consumer,org.apache.kafka.clients.producer.Producer,org.apache.kafka.connect.util.TopicAdmin,org.apache.kafka.connect.util.Callback,org.apache.kafka.common.utils.Time,java.util.function.Consumer,java.util.function.Predicate)

public static KafkaBasedLog<K, V> WithExistingClients(String arg0, Consumer<K, V> arg1, Producer<K, V> arg2, TopicAdmin arg3, Callback<ConsumerRecord<K, V>> arg4, Time arg5, Consumer<TopicAdmin> arg6, Predicate<TopicPartition> arg7)

Parameters

arg0 String

String

arg1 Consumer<K, V>

Consumer

arg2 Producer<K, V>

Producer

arg3 TopicAdmin

TopicAdmin

arg4 Callback<ConsumerRecord<K, V>>

Callback

arg5 Time

Time

arg6 Consumer<TopicAdmin>

Consumer

arg7 Predicate<TopicPartition>

Predicate

Returns

KafkaBasedLog<K, V>

KafkaBasedLog

Operators

implicit operator KafkaBasedLog(KafkaBasedLog<K, V>)

Converter from KafkaBasedLog<K, V> to KafkaBasedLog

public static implicit operator KafkaBasedLog(KafkaBasedLog<K, V> t)

Parameters

t KafkaBasedLog<K, V>

Returns

KafkaBasedLog