Class ConsumerPartitionAssignor
public class ConsumerPartitionAssignor : JVMBridgeListener, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, IConsumerPartitionAssignor- Inheritance
-
JVMBridgeBaseJVMBridgeBase<JVMBridgeListener>JVMBridgeListenerConsumerPartitionAssignor
- Implements
-
IJVMBridgeCoreIJVMBridgeBaseStaticIJVMBridgeBaseIJVMBridgeDefinition
- Derived
- Inherited Members
-
JVMBridgeListener.Dispose()JVMBridgeListener.AutoInitJVMBridgeListener.IsBridgeStaticJVMBridgeListener.IsBridgeCloseableJVMBridgeListener.IsBridgeListenerJVMBridgeBase<JVMBridgeListener>.IsAssignableFrom(IJavaType)JVMBridgeBase<JVMBridgeListener>.IsAssignableFrom<T>()JVMBridgeBase<JVMBridgeListener>.Execute<T>(params T[])JVMBridgeBase<JVMBridgeListener>.DynBridgeClazzJVMBridgeBase<JVMBridgeListener>.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.ToString()JVMBridgeBase.GetHashCode()JVMBridgeBase.Notify()JVMBridgeBase.NotifyAll()JVMBridgeBase.Wait()JVMBridgeBase.IExecuteWithSignature<TNewClass, TReturn, TConverter>(string, string, params object[])JVMBridgeBase.DynBridgeInstanceJVMBridgeBase.BridgeInstanceJVMBridgeBase.IsBridgeInterfaceJVMBridgeBase.IsBridgeAbstract
Constructors
ConsumerPartitionAssignor()
Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge
public ConsumerPartitionAssignor()Properties
BridgeClassName
public override string BridgeClassName { get; }Property Value
OnAssign
public Func<Cluster, ConsumerPartitionAssignor.GroupSubscription, ConsumerPartitionAssignor.GroupAssignment> OnAssign { get; set; }Property Value
- Func<Cluster, ConsumerPartitionAssignor.GroupSubscription, ConsumerPartitionAssignor.GroupAssignment>
Remarks
If OnAssign has a value it takes precedence over corresponding class method
OnName
public Func<String> OnName { get; set; }Property Value
Remarks
If OnName has a value it takes precedence over corresponding class method
OnOnAssignment
public Action<ConsumerPartitionAssignor.Assignment, ConsumerGroupMetadata> OnOnAssignment { get; set; }Property Value
Remarks
If OnOnAssignment has a value it takes precedence over corresponding class method
OnSubscriptionUserData
public Func<Set<String>, ByteBuffer> OnSubscriptionUserData { get; set; }Property Value
- Func<Set<String>, ByteBuffer>
Remarks
If OnSubscriptionUserData has a value it takes precedence over corresponding class method
OnSupportedProtocols
public Func<List<ConsumerPartitionAssignor.RebalanceProtocol>> OnSupportedProtocols { get; set; }Property Value
Remarks
If OnSupportedProtocols has a value it takes precedence over corresponding class method
OnVersion
public Func<short> OnVersion { get; set; }Property Value
Remarks
If OnVersion has a value it takes precedence over corresponding class method
Methods
Assign(Cluster, GroupSubscription)
public virtual ConsumerPartitionAssignor.GroupAssignment Assign(Cluster arg0, ConsumerPartitionAssignor.GroupSubscription arg1)Parameters
Returns
GetAssignorInstances(List<String>, Map<String, object>)
public static List<ConsumerPartitionAssignor> GetAssignorInstances(List<String> arg0, Map<String, object> arg1)Parameters
Returns
Remarks
The method invokes the static implementation in the JVM interface
InitializeHandlers()
Handlers initializer for ConsumerPartitionAssignor
protected virtual void InitializeHandlers()Name()
public virtual String Name()Returns
OnAssignment(Assignment, ConsumerGroupMetadata)
public virtual void OnAssignment(ConsumerPartitionAssignor.Assignment arg0, ConsumerGroupMetadata arg1)Parameters
Remarks
The method invokes the default implementation in the JVM interface using OnAssignmentDefault(Assignment, ConsumerGroupMetadata); override the method to implement a different behavior
OnAssignmentDefault(Assignment, ConsumerGroupMetadata)
public void OnAssignmentDefault(ConsumerPartitionAssignor.Assignment arg0, ConsumerGroupMetadata arg1)Parameters
Remarks
The method invokes the default implementation in the JVM interface
SubscriptionUserData(Set<String>)
public virtual ByteBuffer SubscriptionUserData(Set<String> arg0)Parameters
Returns
Remarks
The method invokes the default implementation in the JVM interface using SubscriptionUserDataDefault(Set<String>); override the method to implement a different behavior
SubscriptionUserDataDefault(Set<String>)
public ByteBuffer SubscriptionUserDataDefault(Set<String> arg0)Parameters
Returns
Remarks
The method invokes the default implementation in the JVM interface
SupportedProtocols()
public virtual List<ConsumerPartitionAssignor.RebalanceProtocol> SupportedProtocols()Returns
Remarks
The method invokes the default implementation in the JVM interface using SupportedProtocolsDefault(); override the method to implement a different behavior
SupportedProtocolsDefault()
public List<ConsumerPartitionAssignor.RebalanceProtocol> SupportedProtocolsDefault()Returns
Remarks
The method invokes the default implementation in the JVM interface
Version()
public virtual short Version()Returns
Remarks
The method invokes the default implementation in the JVM interface using VersionDefault(); override the method to implement a different behavior
VersionDefault()
public short VersionDefault()Returns
Remarks
The method invokes the default implementation in the JVM interface