Class KafkaBasedLog
public class KafkaBasedLog : JVMBridgeBase<KafkaBasedLog>, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition- Inheritance
-
JVMBridgeBaseJVMBridgeBase<KafkaBasedLog>KafkaBasedLog
- Implements
-
IJVMBridgeCoreIJVMBridgeBaseStaticIJVMBridgeBaseIJVMBridgeDefinition
- Inherited Members
-
JVMBridgeBase<KafkaBasedLog>.SExecuteWithSignature(Type, IJavaType, string, string, params object[])JVMBridgeBase<KafkaBasedLog>.SExecute<TReturn, TConverter>(Type, IJavaType, string, params object[])JVMBridgeBase<KafkaBasedLog>.IsAssignableFrom(IJavaType)JVMBridgeBase<KafkaBasedLog>.IsAssignableFrom<T>()JVMBridgeBase<KafkaBasedLog>.Execute<T>(params T[])JVMBridgeBase<KafkaBasedLog>.DynBridgeClazzJVMBridgeBase<KafkaBasedLog>.BridgeClazzJVMBridgeBase.RuntimeClassNameOf<T>()JVMBridgeBase.ClassNameOf<T>()JVMBridgeBase.ClassOf<T>()JVMBridgeBase.WrapsDirect<TNewClass>(IJavaObject)JVMBridgeBase.Wraps<TNewClass>(IJavaObject)JVMBridgeBase.Wraps<TNewClass, TReturn>(IJavaObject)JVMBridgeBase.Wraps<TNewClass, TReturn, TConverter>(IJavaObject)JVMBridgeBase.MonitorEnter()JVMBridgeBase.MonitorExit()JVMBridgeBase.IsInstanceOf(IJavaType)JVMBridgeBase.IsInstanceOf<T>()JVMBridgeBase.RuntimeIsInstanceOf<T>()JVMBridgeBase.CastTo<TNewClass>()JVMBridgeBase.CastDirect<TNewClass>()JVMBridgeBase.Dispose()JVMBridgeBase.ToString()JVMBridgeBase.GetHashCode()JVMBridgeBase.Notify()JVMBridgeBase.NotifyAll()JVMBridgeBase.Wait()JVMBridgeBase.IExecuteWithSignature<TNewClass, TReturn, TConverter>(string, string, params object[])JVMBridgeBase.DynBridgeInstanceJVMBridgeBase.BridgeInstanceJVMBridgeBase.IsBridgeListener
Constructors
KafkaBasedLog()
Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge
public KafkaBasedLog()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(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
public KafkaBasedLog(params object[] args)Parameters
argsobject[]
Properties
BridgeClassName
https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_BridgeClassName.htm
public override string BridgeClassName { get; }Property Value
IsBridgeAbstract
public override bool IsBridgeAbstract { get; }Property Value
IsBridgeCloseable
public override bool IsBridgeCloseable { get; }Property Value
IsBridgeInterface
public override bool IsBridgeInterface { get; }Property Value
IsBridgeStatic
public override bool IsBridgeStatic { get; }Property Value
Methods
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