Class QuorumConfig
https://www.javadoc.io/doc/org.apache.kafka/kafka-raft/4.3.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_MAX_BYTES
public static int DEFAULT_QUORUM_FETCH_MAX_BYTES { get; set; }
Property Value
DEFAULT_QUORUM_FETCH_SNAPSHOT_MAX_BYTES
public static int DEFAULT_QUORUM_FETCH_SNAPSHOT_MAX_BYTES { 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_MAX_BYTES_CONFIG
public static String QUORUM_FETCH_MAX_BYTES_CONFIG { get; set; }
Property Value
QUORUM_FETCH_MAX_BYTES_DOC
public static String QUORUM_FETCH_MAX_BYTES_DOC { get; set; }
Property Value
QUORUM_FETCH_SNAPSHOT_MAX_BYTES_CONFIG
public static String QUORUM_FETCH_SNAPSHOT_MAX_BYTES_CONFIG { get; set; }
Property Value
QUORUM_FETCH_SNAPSHOT_MAX_BYTES_DOC
public static String QUORUM_FETCH_SNAPSHOT_MAX_BYTES_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
FetchMaxBytes()
public int FetchMaxBytes()
Returns
FetchSnapshotMaxBytes()
public int FetchSnapshotMaxBytes()
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()