Class KafkaConsumer
public class KafkaConsumer : Consumer, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBase>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, ICloseable, IAutoCloseable- Inheritance
-
KafkaConsumer
- Implements
- Inherited Members
-
JVMBridgeBase<AutoCloseable>.SExecuteWithSignature(Type, IJavaType, string, string, params object[])JVMBridgeBase<AutoCloseable>.SExecute<TReturn, TConverter>(Type, IJavaType, string, params object[])JVMBridgeBase<AutoCloseable>.SExecuteWithSignatureArray<TArrayType>(string, string, params object[])
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(IJVMBridgeBaseInitializer)
Internal constructor: used internally from JCOBridge
[Obsolete("This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public KafkaConsumer(IJVMBridgeBaseInitializer initializer)Parameters
initializerIJVMBridgeBaseInitializer
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
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 Closeable
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
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(CloseOptions)
public void Close(CloseOptions arg0)Parameters
arg0CloseOptions
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
RegisterMetricForSubscription(KafkaMetric)
public void RegisterMetricForSubscription(KafkaMetric arg0)Parameters
arg0KafkaMetric
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
Subscribe(SubscriptionPattern)
public void Subscribe(SubscriptionPattern arg0)Parameters
Subscribe(SubscriptionPattern, ConsumerRebalanceListener)
public void Subscribe(SubscriptionPattern arg0, ConsumerRebalanceListener arg1)Parameters
arg0SubscriptionPatternarg1ConsumerRebalanceListener
Subscription()
public Set Subscription()Returns
UnregisterMetricFromSubscription(KafkaMetric)
public void UnregisterMetricFromSubscription(KafkaMetric arg0)Parameters
arg0KafkaMetric
Unsubscribe()
public void Unsubscribe()Wakeup()
public void Wakeup()