Table of Contents

Class Cluster

Namespace
Org.Apache.Kafka.Common
Assembly
MASES.KNet.dll

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/common/Cluster.html

public class Cluster : JVMBridgeBase<Cluster>, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBaseInstance>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeBaseInstance, IJVMBridgeDefinition
Inheritance
Cluster
Implements

Constructors

Cluster(String, Collection<Node>, Collection<PartitionInfo>, Set<String>, Set<String>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/common/Cluster.html#%3Cinit%3E(java.lang.String,java.util.Collection,java.util.Collection,java.util.Set,java.util.Set)

public Cluster(String arg0, Collection<Node> arg1, Collection<PartitionInfo> arg2, Set<String> arg3, Set<String> arg4)

Parameters

arg0 String

String

arg1 Collection<Node>

Collection

arg2 Collection<PartitionInfo>

Collection

arg3 Set<String>

Set

arg4 Set<String>

Set

Cluster(String, Collection<Node>, Collection<PartitionInfo>, Set<String>, Set<String>, Set<String>, Node)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/common/Cluster.html#%3Cinit%3E(java.lang.String,java.util.Collection,java.util.Collection,java.util.Set,java.util.Set,java.util.Set,org.apache.kafka.common.Node)

public Cluster(String arg0, Collection<Node> arg1, Collection<PartitionInfo> arg2, Set<String> arg3, Set<String> arg4, Set<String> arg5, Node arg6)

Parameters

arg0 String

String

arg1 Collection<Node>

Collection

arg2 Collection<PartitionInfo>

Collection

arg3 Set<String>

Set

arg4 Set<String>

Set

arg5 Set<String>

Set

arg6 Node

Node

Cluster(String, Collection<Node>, Collection<PartitionInfo>, Set<String>, Set<String>, Set<String>, Node, Map<String, Uuid>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/common/Cluster.html#%3Cinit%3E(java.lang.String,java.util.Collection,java.util.Collection,java.util.Set,java.util.Set,java.util.Set,org.apache.kafka.common.Node,java.util.Map)

public Cluster(String arg0, Collection<Node> arg1, Collection<PartitionInfo> arg2, Set<String> arg3, Set<String> arg4, Set<String> arg5, Node arg6, Map<String, Uuid> arg7)

Parameters

arg0 String

String

arg1 Collection<Node>

Collection

arg2 Collection<PartitionInfo>

Collection

arg3 Set<String>

Set

arg4 Set<String>

Set

arg5 Set<String>

Set

arg6 Node

Node

arg7 Map<String, Uuid>

Map

Cluster(String, Collection<Node>, Collection<PartitionInfo>, Set<String>, Set<String>, Node)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/common/Cluster.html#%3Cinit%3E(java.lang.String,java.util.Collection,java.util.Collection,java.util.Set,java.util.Set,org.apache.kafka.common.Node)

public Cluster(String arg0, Collection<Node> arg1, Collection<PartitionInfo> arg2, Set<String> arg3, Set<String> arg4, Node arg5)

Parameters

arg0 String

String

arg1 Collection<Node>

Collection

arg2 Collection<PartitionInfo>

Collection

arg3 Set<String>

Set

arg4 Set<String>

Set

arg5 Node

Node

Cluster(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 Cluster(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

AvailablePartitionsForTopic(String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/common/Cluster.html#availablePartitionsForTopic(java.lang.String)

public List<PartitionInfo> AvailablePartitionsForTopic(String arg0)

Parameters

arg0 String

String

Returns

List<PartitionInfo>

List

Bootstrap(List<InetSocketAddress>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/common/Cluster.html#bootstrap(java.util.List)

public static Cluster Bootstrap(List<InetSocketAddress> arg0)

Parameters

arg0 List<InetSocketAddress>

List

Returns

Cluster

Cluster

ClusterResource()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/common/Cluster.html#clusterResource()

public ClusterResource ClusterResource()

Returns

ClusterResource

ClusterResource

Controller()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/common/Cluster.html#controller()

public Node Controller()

Returns

Node

Node

CreatePoolableInstance(String, Collection<Node>, Collection<PartitionInfo>, Set<String>, Set<String>)

HPA initializer for Cluster(Java.Lang.String arg0, Java.Util.Collection%3COrg.Apache.Kafka.Common.Node%3E arg1, Java.Util.Collection%3COrg.Apache.Kafka.Common.PartitionInfo%3E arg2, Java.Util.Set%3CJava.Lang.String%3E arg3, Java.Util.Set%3CJava.Lang.String%3E arg4)

public static Cluster CreatePoolableInstance(String arg0, Collection<Node> arg1, Collection<PartitionInfo> arg2, Set<String> arg3, Set<String> arg4)

Parameters

arg0 String
arg1 Collection<Node>
arg2 Collection<PartitionInfo>
arg3 Set<String>
arg4 Set<String>

Returns

Cluster

CreatePoolableInstance(String, Collection<Node>, Collection<PartitionInfo>, Set<String>, Set<String>, Set<String>, Node)

HPA initializer for Cluster(Java.Lang.String arg0, Java.Util.Collection%3COrg.Apache.Kafka.Common.Node%3E arg1, Java.Util.Collection%3COrg.Apache.Kafka.Common.PartitionInfo%3E arg2, Java.Util.Set%3CJava.Lang.String%3E arg3, Java.Util.Set%3CJava.Lang.String%3E arg4, Java.Util.Set%3CJava.Lang.String%3E arg5, Org.Apache.Kafka.Common.Node arg6)

public static Cluster CreatePoolableInstance(String arg0, Collection<Node> arg1, Collection<PartitionInfo> arg2, Set<String> arg3, Set<String> arg4, Set<String> arg5, Node arg6)

Parameters

arg0 String
arg1 Collection<Node>
arg2 Collection<PartitionInfo>
arg3 Set<String>
arg4 Set<String>
arg5 Set<String>
arg6 Node

Returns

Cluster

CreatePoolableInstance(String, Collection<Node>, Collection<PartitionInfo>, Set<String>, Set<String>, Set<String>, Node, Map<String, Uuid>)

HPA initializer for Cluster(Java.Lang.String arg0, Java.Util.Collection%3COrg.Apache.Kafka.Common.Node%3E arg1, Java.Util.Collection%3COrg.Apache.Kafka.Common.PartitionInfo%3E arg2, Java.Util.Set%3CJava.Lang.String%3E arg3, Java.Util.Set%3CJava.Lang.String%3E arg4, Java.Util.Set%3CJava.Lang.String%3E arg5, Org.Apache.Kafka.Common.Node arg6, Java.Util.Map%3CJava.Lang.String, Org.Apache.Kafka.Common.Uuid%3E arg7)

public static Cluster CreatePoolableInstance(String arg0, Collection<Node> arg1, Collection<PartitionInfo> arg2, Set<String> arg3, Set<String> arg4, Set<String> arg5, Node arg6, Map<String, Uuid> arg7)

Parameters

arg0 String
arg1 Collection<Node>
arg2 Collection<PartitionInfo>
arg3 Set<String>
arg4 Set<String>
arg5 Set<String>
arg6 Node
arg7 Map<String, Uuid>

Returns

Cluster

CreatePoolableInstance(String, Collection<Node>, Collection<PartitionInfo>, Set<String>, Set<String>, Node)

HPA initializer for Cluster(Java.Lang.String arg0, Java.Util.Collection%3COrg.Apache.Kafka.Common.Node%3E arg1, Java.Util.Collection%3COrg.Apache.Kafka.Common.PartitionInfo%3E arg2, Java.Util.Set%3CJava.Lang.String%3E arg3, Java.Util.Set%3CJava.Lang.String%3E arg4, Org.Apache.Kafka.Common.Node arg5)

public static Cluster CreatePoolableInstance(String arg0, Collection<Node> arg1, Collection<PartitionInfo> arg2, Set<String> arg3, Set<String> arg4, Node arg5)

Parameters

arg0 String
arg1 Collection<Node>
arg2 Collection<PartitionInfo>
arg3 Set<String>
arg4 Set<String>
arg5 Node

Returns

Cluster

Empty()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/common/Cluster.html#empty()

public static Cluster Empty()

Returns

Cluster

Cluster

InternalTopics()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/common/Cluster.html#internalTopics()

public Set<String> InternalTopics()

Returns

Set<String>

Set

InvalidTopics()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/common/Cluster.html#invalidTopics()

public Set<String> InvalidTopics()

Returns

Set<String>

Set

IsBootstrapConfigured()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/common/Cluster.html#isBootstrapConfigured()

public bool IsBootstrapConfigured()

Returns

bool

bool

LeaderFor(TopicPartition)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/common/Cluster.html#leaderFor(org.apache.kafka.common.TopicPartition)

public Node LeaderFor(TopicPartition arg0)

Parameters

arg0 TopicPartition

TopicPartition

Returns

Node

Node

NodeById(int)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/common/Cluster.html#nodeById(int)

public Node NodeById(int arg0)

Parameters

arg0 int

int

Returns

Node

Node

NodeIfOnline(TopicPartition, int)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/common/Cluster.html#nodeIfOnline(org.apache.kafka.common.TopicPartition,int)

public Optional<Node> NodeIfOnline(TopicPartition arg0, int arg1)

Parameters

arg0 TopicPartition

TopicPartition

arg1 int

int

Returns

Optional<Node>

Optional

Nodes()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/common/Cluster.html#nodes()

public List<Node> Nodes()

Returns

List<Node>

List

Partition(TopicPartition)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/common/Cluster.html#partition(org.apache.kafka.common.TopicPartition)

public PartitionInfo Partition(TopicPartition arg0)

Parameters

arg0 TopicPartition

TopicPartition

Returns

PartitionInfo

PartitionInfo

PartitionCountForTopic(String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/common/Cluster.html#partitionCountForTopic(java.lang.String)

public Integer PartitionCountForTopic(String arg0)

Parameters

arg0 String

String

Returns

Integer

Integer

PartitionsForNode(int)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/common/Cluster.html#partitionsForNode(int)

public List<PartitionInfo> PartitionsForNode(int arg0)

Parameters

arg0 int

int

Returns

List<PartitionInfo>

List

PartitionsForTopic(String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/common/Cluster.html#partitionsForTopic(java.lang.String)

public List<PartitionInfo> PartitionsForTopic(String arg0)

Parameters

arg0 String

String

Returns

List<PartitionInfo>

List

TopicId(String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/common/Cluster.html#topicId(java.lang.String)

public Uuid TopicId(String arg0)

Parameters

arg0 String

String

Returns

Uuid

Uuid

TopicIds()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/common/Cluster.html#topicIds()

public Collection<Uuid> TopicIds()

Returns

Collection<Uuid>

Collection

TopicName(Uuid)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/common/Cluster.html#topicName(org.apache.kafka.common.Uuid)

public String TopicName(Uuid arg0)

Parameters

arg0 Uuid

Uuid

Returns

String

String

Topics()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/common/Cluster.html#topics()

public Set<String> Topics()

Returns

Set<String>

Set

UnauthorizedTopics()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/common/Cluster.html#unauthorizedTopics()

public Set<String> UnauthorizedTopics()

Returns

Set<String>

Set

WithPartitions(Map<TopicPartition, PartitionInfo>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/common/Cluster.html#withPartitions(java.util.Map)

public Cluster WithPartitions(Map<TopicPartition, PartitionInfo> arg0)

Parameters

arg0 Map<TopicPartition, PartitionInfo>

Map

Returns

Cluster

Cluster

Edit this page