Table of Contents

Class QuorumConfig

Namespace
Org.Apache.Kafka.Raft
Assembly
MASES.KNet.dll
public class QuorumConfig : JVMBridgeBase<QuorumConfig>, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBaseInstance>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeBaseInstance, IJVMBridgeDefinition
Inheritance
QuorumConfig
Implements

Constructors

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

Parameters

initializer IJVMBridgeBaseInitializer

QuorumConfig(AbstractConfig)

public QuorumConfig(AbstractConfig arg0)

Parameters

arg0 AbstractConfig

AbstractConfig

Properties

BridgeClassName

Java class name to be instantiated

public override string BridgeClassName { get; }

Property Value

string

CONFIG_DEF

public static ConfigDef CONFIG_DEF { get; set; }

Property Value

ConfigDef

DEFAULT_QUORUM_AUTO_JOIN_ENABLE

public static bool DEFAULT_QUORUM_AUTO_JOIN_ENABLE { get; set; }

Property Value

bool

DEFAULT_QUORUM_BOOTSTRAP_SERVERS

public static List DEFAULT_QUORUM_BOOTSTRAP_SERVERS { get; set; }

Property Value

List

DEFAULT_QUORUM_ELECTION_BACKOFF_MAX_MS

public static int DEFAULT_QUORUM_ELECTION_BACKOFF_MAX_MS { get; set; }

Property Value

int

DEFAULT_QUORUM_ELECTION_TIMEOUT_MS

public static int DEFAULT_QUORUM_ELECTION_TIMEOUT_MS { get; set; }

Property Value

int

DEFAULT_QUORUM_FETCH_TIMEOUT_MS

public static int DEFAULT_QUORUM_FETCH_TIMEOUT_MS { get; set; }

Property Value

int

DEFAULT_QUORUM_LINGER_MS

public static int DEFAULT_QUORUM_LINGER_MS { get; set; }

Property Value

int

DEFAULT_QUORUM_REQUEST_TIMEOUT_MS

public static int DEFAULT_QUORUM_REQUEST_TIMEOUT_MS { get; set; }

Property Value

int

DEFAULT_QUORUM_RETRY_BACKOFF_MS

public static int DEFAULT_QUORUM_RETRY_BACKOFF_MS { get; set; }

Property Value

int

DEFAULT_QUORUM_VOTERS

public static List DEFAULT_QUORUM_VOTERS { get; set; }

Property Value

List

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

NON_ROUTABLE_HOST

public static String NON_ROUTABLE_HOST { get; set; }

Property Value

String

QUORUM_AUTO_JOIN_ENABLE_CONFIG

public static String QUORUM_AUTO_JOIN_ENABLE_CONFIG { get; set; }

Property Value

String

QUORUM_AUTO_JOIN_ENABLE_DOC

public static String QUORUM_AUTO_JOIN_ENABLE_DOC { get; set; }

Property Value

String

QUORUM_BOOTSTRAP_SERVERS_CONFIG

public static String QUORUM_BOOTSTRAP_SERVERS_CONFIG { get; set; }

Property Value

String

QUORUM_BOOTSTRAP_SERVERS_DOC

public static String QUORUM_BOOTSTRAP_SERVERS_DOC { get; set; }

Property Value

String

QUORUM_ELECTION_BACKOFF_MAX_MS_CONFIG

public static String QUORUM_ELECTION_BACKOFF_MAX_MS_CONFIG { get; set; }

Property Value

String

QUORUM_ELECTION_BACKOFF_MAX_MS_DOC

public static String QUORUM_ELECTION_BACKOFF_MAX_MS_DOC { get; set; }

Property Value

String

QUORUM_ELECTION_TIMEOUT_MS_CONFIG

public static String QUORUM_ELECTION_TIMEOUT_MS_CONFIG { get; set; }

Property Value

String

QUORUM_ELECTION_TIMEOUT_MS_DOC

public static String QUORUM_ELECTION_TIMEOUT_MS_DOC { get; set; }

Property Value

String

QUORUM_FETCH_TIMEOUT_MS_CONFIG

public static String QUORUM_FETCH_TIMEOUT_MS_CONFIG { get; set; }

Property Value

String

QUORUM_FETCH_TIMEOUT_MS_DOC

public static String QUORUM_FETCH_TIMEOUT_MS_DOC { get; set; }

Property Value

String

QUORUM_LINGER_MS_CONFIG

public static String QUORUM_LINGER_MS_CONFIG { get; set; }

Property Value

String

QUORUM_LINGER_MS_DOC

public static String QUORUM_LINGER_MS_DOC { get; set; }

Property Value

String

QUORUM_REQUEST_TIMEOUT_MS_CONFIG

public static String QUORUM_REQUEST_TIMEOUT_MS_CONFIG { get; set; }

Property Value

String

QUORUM_REQUEST_TIMEOUT_MS_DOC

public static String QUORUM_REQUEST_TIMEOUT_MS_DOC { get; set; }

Property Value

String

QUORUM_RETRY_BACKOFF_MS_CONFIG

public static String QUORUM_RETRY_BACKOFF_MS_CONFIG { get; set; }

Property Value

String

QUORUM_RETRY_BACKOFF_MS_DOC

public static String QUORUM_RETRY_BACKOFF_MS_DOC { get; set; }

Property Value

String

QUORUM_VOTERS_CONFIG

public static String QUORUM_VOTERS_CONFIG { get; set; }

Property Value

String

QUORUM_VOTERS_DOC

public static String QUORUM_VOTERS_DOC { get; set; }

Property Value

String

Methods

AppendLingerMs()

public int AppendLingerMs()

Returns

int

int

AutoJoin()

public bool AutoJoin()

Returns

bool

bool

BootstrapServers()

public List<String> BootstrapServers()

Returns

List<String>

List

CreatePoolableInstance(AbstractConfig)

HPA initializer for QuorumConfig(Org.Apache.Kafka.Common.Config.AbstractConfig arg0)

public static QuorumConfig CreatePoolableInstance(AbstractConfig arg0)

Parameters

arg0 AbstractConfig

Returns

QuorumConfig

ElectionBackoffMaxMs()

public int ElectionBackoffMaxMs()

Returns

int

int

ElectionTimeoutMs()

public int ElectionTimeoutMs()

Returns

int

int

FetchTimeoutMs()

public int FetchTimeoutMs()

Returns

int

int

ParseBootstrapServers(List<String>)

public static List<InetSocketAddress> ParseBootstrapServers(List<String> arg0)

Parameters

arg0 List<String>

List

Returns

List<InetSocketAddress>

List

ParseVoterConnections(List<String>)

public static Map<Integer, InetSocketAddress> ParseVoterConnections(List<String> arg0)

Parameters

arg0 List<String>

List

Returns

Map<Integer, InetSocketAddress>

Map

ParseVoterIds(List<String>)

public static Set<Integer> ParseVoterIds(List<String> arg0)

Parameters

arg0 List<String>

List

Returns

Set<Integer>

Set

QuorumVoterStringsToNodes(List<String>)

public static List<Node> QuorumVoterStringsToNodes(List<String> arg0)

Parameters

arg0 List<String>

List

Returns

List<Node>

List

RequestTimeoutMs()

public int RequestTimeoutMs()

Returns

int

int

RetryBackoffMs()

public int RetryBackoffMs()

Returns

int

int

VoterConnectionsToNodes(Map<Integer, InetSocketAddress>)

public static List<Node> VoterConnectionsToNodes(Map<Integer, InetSocketAddress> arg0)

Parameters

arg0 Map<Integer, InetSocketAddress>

Map

Returns

List<Node>

List

Voters()

public List<String> Voters()

Returns

List<String>

List