Class StreamsGroupDescription
public class StreamsGroupDescription : JVMBridgeBase<StreamsGroupDescription>, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBaseInstance>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeBaseInstance, IJVMBridgeDefinition
- Inheritance
-
StreamsGroupDescription
- Implements
Constructors
StreamsGroupDescription(String, int, int, int, Collection<StreamsGroupSubtopologyDescription>, Collection<StreamsGroupMemberDescription>, GroupState, Node, Set<AclOperation>)
public StreamsGroupDescription(String arg0, int arg1, int arg2, int arg3, Collection<StreamsGroupSubtopologyDescription> arg4, Collection<StreamsGroupMemberDescription> arg5, GroupState arg6, Node arg7, Set<AclOperation> arg8)
Parameters
arg0Stringarg1intarg2intarg3intarg4Collection<StreamsGroupSubtopologyDescription>arg5Collection<StreamsGroupMemberDescription>arg6GroupStatearg7Nodearg8Set<AclOperation>
StreamsGroupDescription(IJVMBridgeBaseInitializer)
Initializer used internally by JCOBridge. Do not use directly.
[Obsolete("This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public StreamsGroupDescription(IJVMBridgeBaseInitializer initializer)
Parameters
initializerIJVMBridgeBaseInitializer
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 java.lang.AutoCloseable
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
AuthorizedOperations()
public Set<AclOperation> AuthorizedOperations()
Returns
Coordinator()
public Node Coordinator()
Returns
CreatePoolableInstance(String, int, int, int, Collection<StreamsGroupSubtopologyDescription>, Collection<StreamsGroupMemberDescription>, GroupState, Node, Set<AclOperation>)
HPA initializer for StreamsGroupDescription(Java.Lang.String arg0, int arg1, int arg2, int arg3, Java.Util.Collection%3COrg.Apache.Kafka.Clients.Admin.StreamsGroupSubtopologyDescription%3E arg4, Java.Util.Collection%3COrg.Apache.Kafka.Clients.Admin.StreamsGroupMemberDescription%3E arg5, Org.Apache.Kafka.Common.GroupState arg6, Org.Apache.Kafka.Common.Node arg7, Java.Util.Set%3COrg.Apache.Kafka.Common.Acl.AclOperation%3E arg8)
public static StreamsGroupDescription CreatePoolableInstance(String arg0, int arg1, int arg2, int arg3, Collection<StreamsGroupSubtopologyDescription> arg4, Collection<StreamsGroupMemberDescription> arg5, GroupState arg6, Node arg7, Set<AclOperation> arg8)
Parameters
arg0Stringarg1intarg2intarg3intarg4Collection<StreamsGroupSubtopologyDescription>arg5Collection<StreamsGroupMemberDescription>arg6GroupStatearg7Nodearg8Set<AclOperation>
Returns
GroupEpoch()
public int GroupEpoch()
Returns
GroupId()
public String GroupId()
Returns
GroupState()
public GroupState GroupState()
Returns
Members()
public Collection<StreamsGroupMemberDescription> Members()
Returns
Subtopologies()
public Collection<StreamsGroupSubtopologyDescription> Subtopologies()
Returns
TargetAssignmentEpoch()
public int TargetAssignmentEpoch()
Returns
TopologyEpoch()
public int TopologyEpoch()