Class KafkaConsumer
public class KafkaConsumer : Consumer, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, ICloseable, IAutoCloseable- Inheritance
-
JVMBridgeBaseJVMBridgeBase<AutoCloseable>KafkaConsumer
- 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
KafkaConsumer()
Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge
public KafkaConsumer()KafkaConsumer(Map)
public KafkaConsumer(Map arg0)Parameters
KafkaConsumer(Map, Deserializer, Deserializer)
public KafkaConsumer(Map arg0, Deserializer arg1, Deserializer arg2)Parameters
arg0Maparg1Deserializerarg2Deserializer
KafkaConsumer(Properties)
public KafkaConsumer(Properties arg0)Parameters
arg0Properties
KafkaConsumer(Properties, Deserializer, Deserializer)
public KafkaConsumer(Properties arg0, Deserializer arg1, Deserializer arg2)Parameters
arg0Propertiesarg1Deserializerarg2Deserializer
KafkaConsumer(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 KafkaConsumer(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
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
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
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
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
Resume(Collection)
public void Resume(Collection arg0)Parameters
arg0Collection
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
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()Wakeup()
public void Wakeup()