Class MockConsumer
public class MockConsumer : Consumer, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, ICloseable, IAutoCloseable- Inheritance
-
JVMBridgeBaseJVMBridgeBase<AutoCloseable>MockConsumer
- Implements
-
IJVMBridgeCoreIJVMBridgeBaseStaticIJVMBridgeBaseIJVMBridgeDefinition
- Inherited Members
-
JVMBridgeBase<AutoCloseable>.SExecuteWithSignature(Type, IJavaType, string, string, params object[])JVMBridgeBase<AutoCloseable>.SExecute<TReturn, TConverter>(Type, IJavaType, string, params object[])JVMBridgeBase<AutoCloseable>.IsAssignableFrom(IJavaType)JVMBridgeBase<AutoCloseable>.IsAssignableFrom<T>()JVMBridgeBase<AutoCloseable>.Execute<T>(params T[])JVMBridgeBase<AutoCloseable>.DynBridgeClazzJVMBridgeBase<AutoCloseable>.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
MockConsumer()
Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge
public MockConsumer()MockConsumer(OffsetResetStrategy)
public MockConsumer(OffsetResetStrategy arg0)Parameters
MockConsumer(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 MockConsumer(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
AddRecord(ConsumerRecord)
public void AddRecord(ConsumerRecord arg0)Parameters
Assign(Collection)
public void Assign(Collection arg0)Parameters
arg0Collection
Assignment()
public Set Assignment()Returns
BeginningOffsets(Collection)
public Map BeginningOffsets(Collection arg0)Parameters
arg0Collection
Returns
BeginningOffsets(Collection, Duration)
public Map BeginningOffsets(Collection arg0, Duration arg1)Parameters
arg0Collectionarg1Duration
Returns
ClientInstanceId(Duration)
public Uuid ClientInstanceId(Duration arg0)Parameters
Returns
Close()
public void Close()Close(Duration)
public void Close(Duration arg0)Parameters
Closed()
public bool Closed()Returns
CommitAsync()
public void CommitAsync()CommitAsync(Map, OffsetCommitCallback)
public void CommitAsync(Map arg0, OffsetCommitCallback arg1)Parameters
arg0Maparg1OffsetCommitCallback
CommitAsync(OffsetCommitCallback)
public void CommitAsync(OffsetCommitCallback arg0)Parameters
CommitSync()
public void CommitSync()CommitSync(Duration)
public void CommitSync(Duration arg0)Parameters
CommitSync(Map)
public void CommitSync(Map arg0)Parameters
CommitSync(Map, Duration)
public void CommitSync(Map arg0, Duration arg1)Parameters
Committed(Set)
public Map Committed(Set arg0)Parameters
Returns
Committed(Set, Duration)
public Map Committed(Set arg0, Duration arg1)Parameters
Returns
CurrentLag(TopicPartition)
public OptionalLong CurrentLag(TopicPartition arg0)Parameters
Returns
DisableTelemetry()
public void DisableTelemetry()EndOffsets(Collection)
public Map EndOffsets(Collection arg0)Parameters
arg0Collection
Returns
EndOffsets(Collection, Duration)
public Map EndOffsets(Collection arg0, Duration arg1)Parameters
arg0Collectionarg1Duration
Returns
EnforceRebalance()
public void EnforceRebalance()EnforceRebalance(String)
public void EnforceRebalance(String arg0)Parameters
GroupMetadata()
public ConsumerGroupMetadata GroupMetadata()Returns
InjectTimeoutException(int)
public void InjectTimeoutException(int arg0)Parameters
LastPollTimeout()
public Duration LastPollTimeout()Returns
ListTopics()
public Map ListTopics()Returns
ListTopics(Duration)
public Map ListTopics(Duration arg0)Parameters
Returns
Metrics()
public Map Metrics()Returns
OffsetsForTimes(Map)
public Map OffsetsForTimes(Map arg0)Parameters
Returns
OffsetsForTimes(Map, Duration)
public Map OffsetsForTimes(Map arg0, Duration arg1)Parameters
Returns
PartitionsFor(String)
public List PartitionsFor(String arg0)Parameters
Returns
PartitionsFor(String, Duration)
public List PartitionsFor(String arg0, Duration arg1)Parameters
Returns
Pause(Collection)
public void Pause(Collection arg0)Parameters
arg0Collection
Paused()
public Set Paused()Returns
Poll(Duration)
public ConsumerRecords Poll(Duration arg0)Parameters
Returns
Position(TopicPartition)
public long Position(TopicPartition arg0)Parameters
Returns
Position(TopicPartition, Duration)
public long Position(TopicPartition arg0, Duration arg1)Parameters
arg0TopicPartitionarg1Duration
Returns
Rebalance(Collection)
public void Rebalance(Collection arg0)Parameters
arg0Collection
ResetShouldRebalance()
public void ResetShouldRebalance()Resume(Collection)
public void Resume(Collection arg0)Parameters
arg0Collection
ScheduleNopPollTask()
public void ScheduleNopPollTask()SchedulePollTask(Runnable)
public void SchedulePollTask(Runnable arg0)Parameters
Seek(TopicPartition, OffsetAndMetadata)
public void Seek(TopicPartition arg0, OffsetAndMetadata arg1)Parameters
Seek(TopicPartition, long)
public void Seek(TopicPartition arg0, long arg1)Parameters
arg0TopicPartitionarg1long
SeekToBeginning(Collection)
public void SeekToBeginning(Collection arg0)Parameters
arg0Collection
SeekToEnd(Collection)
public void SeekToEnd(Collection arg0)Parameters
arg0Collection
SetClientInstanceId(Uuid)
public void SetClientInstanceId(Uuid arg0)Parameters
SetOffsetsException(JVMBridgeException)
public void SetOffsetsException(JVMBridgeException arg0)Parameters
arg0JVMBridgeException
SetPollException(JVMBridgeException)
public void SetPollException(JVMBridgeException arg0)Parameters
arg0JVMBridgeException
ShouldRebalance()
public bool ShouldRebalance()Returns
Subscribe(Collection)
public void Subscribe(Collection arg0)Parameters
arg0Collection
Subscribe(Collection, ConsumerRebalanceListener)
public void Subscribe(Collection arg0, ConsumerRebalanceListener arg1)Parameters
Subscribe(Pattern)
public void Subscribe(Pattern arg0)Parameters
Subscribe(Pattern, ConsumerRebalanceListener)
public void Subscribe(Pattern arg0, ConsumerRebalanceListener arg1)Parameters
Subscription()
public Set Subscription()Returns
Unsubscribe()
public void Unsubscribe()UpdateBeginningOffsets(Map)
public void UpdateBeginningOffsets(Map arg0)Parameters
UpdateEndOffsets(Map)
public void UpdateEndOffsets(Map arg0)Parameters
UpdatePartitions(String, List)
public void UpdatePartitions(String arg0, List arg1)Parameters
Wakeup()
public void Wakeup()