Class KafkaBasedLog
public class KafkaBasedLog : JVMBridgeBase<KafkaBasedLog>, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBaseInstance>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeBaseInstance, IJVMBridgeDefinition- Inheritance
-
KafkaBasedLog
- Implements
Constructors
KafkaBasedLog(String, Map, Map, Supplier, Callback, Time, Consumer)
public KafkaBasedLog(String arg0, Map arg1, Map arg2, Supplier arg3, Callback arg4, Time arg5, Consumer arg6)Parameters
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
initializerIJVMBridgeBaseInitializer
Properties
BridgeClassName
Java class name to be instantiated
public override string BridgeClassName { get; }Property Value
IsBridgeAbstract
true if the BridgeClassName is an abstract class, i.e. cannot be created an instance
public override bool IsBridgeAbstract { get; }Property Value
IsBridgeCloseable
true if the BridgeClassName implements java.lang.AutoCloseable
public override bool IsBridgeCloseable { get; }Property Value
IsBridgeInterface
true if the BridgeClassName is an interface, i.e. does not have any public constructor
public override bool IsBridgeInterface { get; }Property Value
IsBridgeStatic
true if the BridgeClassName is a static class, i.e. does not have any public constructor
public override bool IsBridgeStatic { get; }Property Value
Methods
CreatePoolableInstance(String, Map, Map, Supplier, Callback, Time, Consumer)
HPA initializer for KafkaBasedLog(Java.Lang.String arg0, Java.Util.Map arg1, Java.Util.Map arg2, Java.Util.Function.Supplier arg3, Org.Apache.Kafka.Connect.Util.Callback arg4, Org.Apache.Kafka.Common.Utils.Time arg5, Java.Util.Function.Consumer arg6)
public static KafkaBasedLog CreatePoolableInstance(String arg0, Map arg1, Map arg2, Supplier arg3, Callback arg4, Time arg5, Consumer arg6)Parameters
Returns
Flush()
public void Flush()PartitionCount()
public int PartitionCount()Returns
ReadToEnd()
public Future ReadToEnd()Returns
ReadToEnd(Callback)
public void ReadToEnd(Callback arg0)Parameters
Send(object, object)
public void Send(object arg0, object arg1)Parameters
Send(object, object, Callback)
public void Send(object arg0, object arg1, Callback arg2)Parameters
SendWithReceipt(object, object)
public Future SendWithReceipt(object arg0, object arg1)Parameters
Returns
SendWithReceipt(object, object, Callback)
public Future SendWithReceipt(object arg0, object arg1, Callback arg2)Parameters
Returns
Start()
public void Start()Start(bool)
public void Start(bool arg0)Parameters
Stop()
public void Stop()WithExistingClients(String, Consumer, Producer, TopicAdmin, Callback, Time, Consumer, Predicate)
public static KafkaBasedLog WithExistingClients(String arg0, Consumer arg1, Producer arg2, TopicAdmin arg3, Callback arg4, Time arg5, Consumer arg6, Predicate arg7)Parameters
arg0Stringarg1Consumerarg2Producerarg3TopicAdminarg4Callbackarg5Timearg6Consumerarg7Predicate