Class QuorumConfig
https://www.javadoc.io/doc/org.apache.kafka/kafka-raft/4.2.1/org/apache/kafka/raft/QuorumConfig.html
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
initializerIJVMBridgeBaseInitializer
QuorumConfig(AbstractConfig)
public QuorumConfig(AbstractConfig arg0)
Parameters
Properties
BridgeClassName
Java class name to be instantiated
public override string BridgeClassName { get; }
Property Value
CONFIG_DEF
public static ConfigDef CONFIG_DEF { get; set; }
Property Value
DEFAULT_QUORUM_AUTO_JOIN_ENABLE
public static bool DEFAULT_QUORUM_AUTO_JOIN_ENABLE { get; set; }
Property Value
DEFAULT_QUORUM_BOOTSTRAP_SERVERS
public static List DEFAULT_QUORUM_BOOTSTRAP_SERVERS { get; set; }
Property Value
DEFAULT_QUORUM_ELECTION_BACKOFF_MAX_MS
public static int DEFAULT_QUORUM_ELECTION_BACKOFF_MAX_MS { get; set; }
Property Value
DEFAULT_QUORUM_ELECTION_TIMEOUT_MS
public static int DEFAULT_QUORUM_ELECTION_TIMEOUT_MS { get; set; }
Property Value
DEFAULT_QUORUM_FETCH_TIMEOUT_MS
public static int DEFAULT_QUORUM_FETCH_TIMEOUT_MS { get; set; }
Property Value
DEFAULT_QUORUM_LINGER_MS
public static int DEFAULT_QUORUM_LINGER_MS { get; set; }
Property Value
DEFAULT_QUORUM_REQUEST_TIMEOUT_MS
public static int DEFAULT_QUORUM_REQUEST_TIMEOUT_MS { get; set; }
Property Value
DEFAULT_QUORUM_RETRY_BACKOFF_MS
public static int DEFAULT_QUORUM_RETRY_BACKOFF_MS { get; set; }
Property Value
DEFAULT_QUORUM_VOTERS
public static List DEFAULT_QUORUM_VOTERS { get; set; }
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
NON_ROUTABLE_HOST
public static String NON_ROUTABLE_HOST { get; set; }
Property Value
QUORUM_AUTO_JOIN_ENABLE_CONFIG
public static String QUORUM_AUTO_JOIN_ENABLE_CONFIG { get; set; }
Property Value
QUORUM_AUTO_JOIN_ENABLE_DOC
public static String QUORUM_AUTO_JOIN_ENABLE_DOC { get; set; }
Property Value
QUORUM_BOOTSTRAP_SERVERS_CONFIG
public static String QUORUM_BOOTSTRAP_SERVERS_CONFIG { get; set; }
Property Value
QUORUM_BOOTSTRAP_SERVERS_DOC
public static String QUORUM_BOOTSTRAP_SERVERS_DOC { get; set; }
Property Value
QUORUM_ELECTION_BACKOFF_MAX_MS_CONFIG
public static String QUORUM_ELECTION_BACKOFF_MAX_MS_CONFIG { get; set; }
Property Value
QUORUM_ELECTION_BACKOFF_MAX_MS_DOC
public static String QUORUM_ELECTION_BACKOFF_MAX_MS_DOC { get; set; }
Property Value
QUORUM_ELECTION_TIMEOUT_MS_CONFIG
public static String QUORUM_ELECTION_TIMEOUT_MS_CONFIG { get; set; }
Property Value
QUORUM_ELECTION_TIMEOUT_MS_DOC
public static String QUORUM_ELECTION_TIMEOUT_MS_DOC { get; set; }
Property Value
QUORUM_FETCH_TIMEOUT_MS_CONFIG
public static String QUORUM_FETCH_TIMEOUT_MS_CONFIG { get; set; }
Property Value
QUORUM_FETCH_TIMEOUT_MS_DOC
public static String QUORUM_FETCH_TIMEOUT_MS_DOC { get; set; }
Property Value
QUORUM_LINGER_MS_CONFIG
public static String QUORUM_LINGER_MS_CONFIG { get; set; }
Property Value
QUORUM_LINGER_MS_DOC
public static String QUORUM_LINGER_MS_DOC { get; set; }
Property Value
QUORUM_REQUEST_TIMEOUT_MS_CONFIG
public static String QUORUM_REQUEST_TIMEOUT_MS_CONFIG { get; set; }
Property Value
QUORUM_REQUEST_TIMEOUT_MS_DOC
public static String QUORUM_REQUEST_TIMEOUT_MS_DOC { get; set; }
Property Value
QUORUM_RETRY_BACKOFF_MS_CONFIG
public static String QUORUM_RETRY_BACKOFF_MS_CONFIG { get; set; }
Property Value
QUORUM_RETRY_BACKOFF_MS_DOC
public static String QUORUM_RETRY_BACKOFF_MS_DOC { get; set; }
Property Value
QUORUM_VOTERS_CONFIG
public static String QUORUM_VOTERS_CONFIG { get; set; }
Property Value
QUORUM_VOTERS_DOC
public static String QUORUM_VOTERS_DOC { get; set; }
Property Value
Methods
AppendLingerMs()
public int AppendLingerMs()
Returns
AutoJoin()
public bool AutoJoin()
Returns
BootstrapServers()
public List<String> BootstrapServers()
Returns
CreatePoolableInstance(AbstractConfig)
HPA initializer for QuorumConfig(Org.Apache.Kafka.Common.Config.AbstractConfig arg0)
public static QuorumConfig CreatePoolableInstance(AbstractConfig arg0)
Parameters
arg0AbstractConfig
Returns
ElectionBackoffMaxMs()
public int ElectionBackoffMaxMs()
Returns
ElectionTimeoutMs()
public int ElectionTimeoutMs()
Returns
FetchTimeoutMs()
public int FetchTimeoutMs()
Returns
ParseBootstrapServers(List<String>)
public static List<InetSocketAddress> ParseBootstrapServers(List<String> arg0)
Parameters
Returns
ParseVoterConnections(List<String>)
public static Map<Integer, InetSocketAddress> ParseVoterConnections(List<String> arg0)
Parameters
Returns
ParseVoterIds(List<String>)
public static Set<Integer> ParseVoterIds(List<String> arg0)
Parameters
Returns
QuorumVoterStringsToNodes(List<String>)
public static List<Node> QuorumVoterStringsToNodes(List<String> arg0)
Parameters
Returns
RequestTimeoutMs()
public int RequestTimeoutMs()
Returns
RetryBackoffMs()
public int RetryBackoffMs()
Returns
VoterConnectionsToNodes(Map<Integer, InetSocketAddress>)
public static List<Node> VoterConnectionsToNodes(Map<Integer, InetSocketAddress> arg0)
Parameters
arg0Map<Integer, InetSocketAddress>
Returns
Voters()
public List<String> Voters()