Table of Contents

Class AssignmentConfigs

Namespace
Org.Apache.Kafka.Streams.Processor.Assignment
Assembly
MASES.KNet.dll

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/processor/assignment/AssignmentConfigs.html

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

Constructors

AssignmentConfigs(Long, Integer, Integer, Long, List<String>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/processor/assignment/AssignmentConfigs.html#%3Cinit%3E(java.lang.Long,java.lang.Integer,java.lang.Integer,java.lang.Long,java.util.List)

public AssignmentConfigs(Long arg0, Integer arg1, Integer arg2, Long arg3, List<String> arg4)

Parameters

arg0 Long

Long

arg1 Integer

Integer

arg2 Integer

Integer

arg3 Long

Long

arg4 List<String>

List

AssignmentConfigs(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 AssignmentConfigs(IJVMBridgeBaseInitializer initializer)

Parameters

initializer IJVMBridgeBaseInitializer

AssignmentConfigs(long, int, int, long, List<String>, OptionalInt, OptionalInt, String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/processor/assignment/AssignmentConfigs.html#%3Cinit%3E(long,int,int,long,java.util.List,java.util.OptionalInt,java.util.OptionalInt,java.lang.String)

public AssignmentConfigs(long arg0, int arg1, int arg2, long arg3, List<String> arg4, OptionalInt arg5, OptionalInt arg6, String arg7)

Parameters

arg0 long

long

arg1 int

int

arg2 int

int

arg3 long

long

arg4 List<String>

List

arg5 OptionalInt

OptionalInt

arg6 OptionalInt

OptionalInt

arg7 String

String

AssignmentConfigs(long, int, int, long, List<String>, int, int, String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/processor/assignment/AssignmentConfigs.html#%3Cinit%3E(long,int,int,long,java.util.List,int,int,java.lang.String)

public AssignmentConfigs(long arg0, int arg1, int arg2, long arg3, List<String> arg4, int arg5, int arg6, String arg7)

Parameters

arg0 long

long

arg1 int

int

arg2 int

int

arg3 long

long

arg4 List<String>

List

arg5 int

int

arg6 int

int

arg7 String

String

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

AcceptableRecoveryLag()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/processor/assignment/AssignmentConfigs.html#acceptableRecoveryLag()

public long AcceptableRecoveryLag()

Returns

long

long

CreatePoolableInstance(Long, Integer, Integer, Long, List<String>)

HPA initializer for AssignmentConfigs(Java.Lang.Long arg0, Java.Lang.Integer arg1, Java.Lang.Integer arg2, Java.Lang.Long arg3, Java.Util.List%3CJava.Lang.String%3E arg4)

public static AssignmentConfigs CreatePoolableInstance(Long arg0, Integer arg1, Integer arg2, Long arg3, List<String> arg4)

Parameters

arg0 Long
arg1 Integer
arg2 Integer
arg3 Long
arg4 List<String>

Returns

AssignmentConfigs

CreatePoolableInstance(long, int, int, long, List<String>, OptionalInt, OptionalInt, String)

HPA initializer for AssignmentConfigs(long arg0, int arg1, int arg2, long arg3, Java.Util.List%3CJava.Lang.String%3E arg4, Java.Util.OptionalInt arg5, Java.Util.OptionalInt arg6, Java.Lang.String arg7)

public static AssignmentConfigs CreatePoolableInstance(long arg0, int arg1, int arg2, long arg3, List<String> arg4, OptionalInt arg5, OptionalInt arg6, String arg7)

Parameters

arg0 long
arg1 int
arg2 int
arg3 long
arg4 List<String>
arg5 OptionalInt
arg6 OptionalInt
arg7 String

Returns

AssignmentConfigs

CreatePoolableInstance(long, int, int, long, List<String>, int, int, String)

HPA initializer for AssignmentConfigs(long arg0, int arg1, int arg2, long arg3, Java.Util.List%3CJava.Lang.String%3E arg4, int arg5, int arg6, Java.Lang.String arg7)

public static AssignmentConfigs CreatePoolableInstance(long arg0, int arg1, int arg2, long arg3, List<String> arg4, int arg5, int arg6, String arg7)

Parameters

arg0 long
arg1 int
arg2 int
arg3 long
arg4 List<String>
arg5 int
arg6 int
arg7 String

Returns

AssignmentConfigs

MaxWarmupReplicas()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/processor/assignment/AssignmentConfigs.html#maxWarmupReplicas()

public int MaxWarmupReplicas()

Returns

int

int

NumStandbyReplicas()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/processor/assignment/AssignmentConfigs.html#numStandbyReplicas()

public int NumStandbyReplicas()

Returns

int

int

Of(StreamsConfig)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/processor/assignment/AssignmentConfigs.html#of(org.apache.kafka.streams.StreamsConfig)

public static AssignmentConfigs Of(StreamsConfig arg0)

Parameters

arg0 StreamsConfig

StreamsConfig

Returns

AssignmentConfigs

AssignmentConfigs

ProbingRebalanceIntervalMs()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/processor/assignment/AssignmentConfigs.html#probingRebalanceIntervalMs()

public long ProbingRebalanceIntervalMs()

Returns

long

long

RackAwareAssignmentStrategy()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/processor/assignment/AssignmentConfigs.html#rackAwareAssignmentStrategy()

public String RackAwareAssignmentStrategy()

Returns

String

String

RackAwareAssignmentTags()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/processor/assignment/AssignmentConfigs.html#rackAwareAssignmentTags()

public List<String> RackAwareAssignmentTags()

Returns

List<String>

List

RackAwareNonOverlapCost()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/processor/assignment/AssignmentConfigs.html#rackAwareNonOverlapCost()

public OptionalInt RackAwareNonOverlapCost()

Returns

OptionalInt

OptionalInt

RackAwareTrafficCost()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/processor/assignment/AssignmentConfigs.html#rackAwareTrafficCost()

public OptionalInt RackAwareTrafficCost()

Returns

OptionalInt

OptionalInt

Edit this page