Class Consumer<K, V>
public class Consumer<K, V> : Closeable, IDynamicMetaObjectProvider, IJVMBridgeCore, IJVMBridgeBaseStatic, IConsumer<K, V>, IConsumer, IJVMBridgeBase, IJVMBridgeDefinition, IDisposable, ICloseable, IAutoCloseable
Type Parameters
K
V
- Inheritance
-
JVMBridgeBaseJVMBridgeBase<AutoCloseable>Consumer<K, V>
- Implements
-
IJVMBridgeCoreIJVMBridgeBaseStaticIConsumer<K, V>IJVMBridgeBaseIJVMBridgeDefinition
- Derived
- 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
- Extension Methods
Constructors
Consumer()
Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge
[Obsolete("Consumer class represents, in .NET, an instance of a JVM interface or abstract class. This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public Consumer()
Consumer(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
[Obsolete("Consumer class represents, in .NET, an instance of a JVM interface or abstract class. This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public Consumer(params object[] args)
Parameters
args
object[]
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<TopicPartition>)
public void Assign(Collection<TopicPartition> arg0)
Parameters
Assignment()
public Set<TopicPartition> Assignment()
Returns
BeginningOffsets(Collection<TopicPartition>)
public Map<TopicPartition, Long> BeginningOffsets(Collection<TopicPartition> arg0)
Parameters
Returns
BeginningOffsets(Collection<TopicPartition>, Duration)
public Map<TopicPartition, Long> BeginningOffsets(Collection<TopicPartition> arg0, Duration arg1)
Parameters
arg0
Collection<TopicPartition>arg1
Duration
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<TopicPartition, OffsetAndMetadata>, OffsetCommitCallback)
public void CommitAsync(Map<TopicPartition, OffsetAndMetadata> arg0, OffsetCommitCallback arg1)
Parameters
CommitAsync(OffsetCommitCallback)
public void CommitAsync(OffsetCommitCallback arg0)
Parameters
CommitSync()
public void CommitSync()
CommitSync(Duration)
public void CommitSync(Duration arg0)
Parameters
CommitSync(Map<TopicPartition, OffsetAndMetadata>)
public void CommitSync(Map<TopicPartition, OffsetAndMetadata> arg0)
Parameters
arg0
Map<TopicPartition, OffsetAndMetadata>
CommitSync(Map<TopicPartition, OffsetAndMetadata>, Duration)
public void CommitSync(Map<TopicPartition, OffsetAndMetadata> arg0, Duration arg1)
Parameters
arg0
Map<TopicPartition, OffsetAndMetadata>arg1
Duration
Committed(Set<TopicPartition>)
public Map<TopicPartition, OffsetAndMetadata> Committed(Set<TopicPartition> arg0)
Parameters
arg0
Set<TopicPartition>
Returns
Committed(Set<TopicPartition>, Duration)
public Map<TopicPartition, OffsetAndMetadata> Committed(Set<TopicPartition> arg0, Duration arg1)
Parameters
arg0
Set<TopicPartition>arg1
Duration
Returns
CurrentLag(TopicPartition)
public OptionalLong CurrentLag(TopicPartition arg0)
Parameters
Returns
EndOffsets(Collection<TopicPartition>)
public Map<TopicPartition, Long> EndOffsets(Collection<TopicPartition> arg0)
Parameters
Returns
EndOffsets(Collection<TopicPartition>, Duration)
public Map<TopicPartition, Long> EndOffsets(Collection<TopicPartition> arg0, Duration arg1)
Parameters
arg0
Collection<TopicPartition>arg1
Duration
Returns
EnforceRebalance()
public void EnforceRebalance()
EnforceRebalance(String)
public void EnforceRebalance(String arg0)
Parameters
GroupMetadata()
public ConsumerGroupMetadata GroupMetadata()
Returns
ListTopics()
public Map<String, List<PartitionInfo>> ListTopics()
Returns
ListTopics(Duration)
public Map<String, List<PartitionInfo>> ListTopics(Duration arg0)
Parameters
Returns
Metrics<ReturnExtendsOrg_Apache_Kafka_Common_Metric>()
public Map<MetricName, ReturnExtendsOrg_Apache_Kafka_Common_Metric> Metrics<ReturnExtendsOrg_Apache_Kafka_Common_Metric>() where ReturnExtendsOrg_Apache_Kafka_Common_Metric : Metric
Returns
- Map<MetricName, ReturnExtendsOrg_Apache_Kafka_Common_Metric>
Type Parameters
ReturnExtendsOrg_Apache_Kafka_Common_Metric
OffsetsForTimes(Map<TopicPartition, Long>)
public Map<TopicPartition, OffsetAndTimestamp> OffsetsForTimes(Map<TopicPartition, Long> arg0)
Parameters
arg0
Map<TopicPartition, Long>
Returns
OffsetsForTimes(Map<TopicPartition, Long>, Duration)
public Map<TopicPartition, OffsetAndTimestamp> OffsetsForTimes(Map<TopicPartition, Long> arg0, Duration arg1)
Parameters
Returns
PartitionsFor(String)
public List<PartitionInfo> PartitionsFor(String arg0)
Parameters
Returns
PartitionsFor(String, Duration)
public List<PartitionInfo> PartitionsFor(String arg0, Duration arg1)
Parameters
Returns
Pause(Collection<TopicPartition>)
public void Pause(Collection<TopicPartition> arg0)
Parameters
Paused()
public Set<TopicPartition> Paused()
Returns
Poll(Duration)
public ConsumerRecords<K, V> 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
arg0
TopicPartitionarg1
Duration
Returns
RegisterMetricForSubscription(KafkaMetric)
public void RegisterMetricForSubscription(KafkaMetric arg0)
Parameters
arg0
KafkaMetric
Resume(Collection<TopicPartition>)
public void Resume(Collection<TopicPartition> arg0)
Parameters
Seek(TopicPartition, OffsetAndMetadata)
public void Seek(TopicPartition arg0, OffsetAndMetadata arg1)
Parameters
Seek(TopicPartition, long)
public void Seek(TopicPartition arg0, long arg1)
Parameters
arg0
TopicPartitionarg1
long
SeekToBeginning(Collection<TopicPartition>)
public void SeekToBeginning(Collection<TopicPartition> arg0)
Parameters
SeekToEnd(Collection<TopicPartition>)
public void SeekToEnd(Collection<TopicPartition> arg0)
Parameters
Subscribe(Collection<String>)
public void Subscribe(Collection<String> arg0)
Parameters
arg0
Collection<String>
Subscribe(Collection<String>, ConsumerRebalanceListener)
public void Subscribe(Collection<String> 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
arg0
SubscriptionPatternarg1
ConsumerRebalanceListener
Subscription()
public Set<String> Subscription()
Returns
UnregisterMetricFromSubscription(KafkaMetric)
public void UnregisterMetricFromSubscription(KafkaMetric arg0)
Parameters
arg0
KafkaMetric
Unsubscribe()
public void Unsubscribe()
Wakeup()
public void Wakeup()
Operators
implicit operator Consumer(Consumer<K, V>)
Converter from Consumer<K, V> to Consumer
public static implicit operator Consumer(Consumer<K, V> t)
Parameters
t
Consumer<K, V>