Table of Contents

Class StreamsGroupDescription

Namespace
Org.Apache.Kafka.Clients.Admin
Assembly
MASES.KNet.dll
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

arg0 String

String

arg1 int

int

arg2 int

int

arg3 int

int

arg4 Collection<StreamsGroupSubtopologyDescription>

Collection

arg5 Collection<StreamsGroupMemberDescription>

Collection

arg6 GroupState

GroupState

arg7 Node

Node

arg8 Set<AclOperation>

Set

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

initializer IJVMBridgeBaseInitializer

Properties

BridgeClassName

Java class name to be instantiated

public override string BridgeClassName { get; }

Property Value

string

IsBridgeAbstract

true if the BridgeClassName is an abstract class, i.e. cannot be created an instance

public override bool IsBridgeAbstract { get; }

Property Value

bool

IsBridgeCloseable

true if the BridgeClassName implements java.lang.AutoCloseable

public override bool IsBridgeCloseable { get; }

Property Value

bool

IsBridgeInterface

true if the BridgeClassName is an interface, i.e. does not have any public constructor

public override bool IsBridgeInterface { get; }

Property Value

bool

IsBridgeStatic

true if the BridgeClassName is a static class, i.e. does not have any public constructor

public override bool IsBridgeStatic { get; }

Property Value

bool

Methods

AuthorizedOperations()

public Set<AclOperation> AuthorizedOperations()

Returns

Set<AclOperation>

Set

Coordinator()

public Node Coordinator()

Returns

Node

Node

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

arg0 String
arg1 int
arg2 int
arg3 int
arg4 Collection<StreamsGroupSubtopologyDescription>
arg5 Collection<StreamsGroupMemberDescription>
arg6 GroupState
arg7 Node
arg8 Set<AclOperation>

Returns

StreamsGroupDescription

GroupEpoch()

public int GroupEpoch()

Returns

int

int

GroupId()

public String GroupId()

Returns

String

String

GroupState()

public GroupState GroupState()

Returns

GroupState

GroupState

Members()

public Collection<StreamsGroupMemberDescription> Members()

Returns

Collection<StreamsGroupMemberDescription>

Collection

Subtopologies()

public Collection<StreamsGroupSubtopologyDescription> Subtopologies()

Returns

Collection<StreamsGroupSubtopologyDescription>

Collection

TargetAssignmentEpoch()

public int TargetAssignmentEpoch()

Returns

int

int

TopologyEpoch()

public int TopologyEpoch()

Returns

int

int