Class CommonClientConfigsBuilder<T>
Common builder for CommonClientConfigs
public abstract class CommonClientConfigsBuilder<T> : GenericConfigBuilder<T>, INotifyPropertyChanged, IGenericSerDesFactory, IDisposable where T : CommonClientConfigsBuilder<T>, new()
Type Parameters
T
A tpe implementing CommonClientConfigsBuilder<T>
- Inheritance
-
CommonClientConfigsBuilder<T>
- Implements
- Derived
- Inherited Members
Properties
BootstrapServers
Manages BOOTSTRAP_SERVERS_CONFIG
public string BootstrapServers { get; set; }
Property Value
ClientDnsLookup
Manages CLIENT_DNS_LOOKUP_CONFIG
public string ClientDnsLookup { get; set; }
Property Value
ClientId
Manages CLIENT_ID_CONFIG
public string ClientId { get; set; }
Property Value
ClientRack
Manages CLIENT_RACK_CONFIG
public string ClientRack { get; set; }
Property Value
ConnectionMaxIdleMs
Manages CONNECTIONS_MAX_IDLE_MS_CONFIG
public long ConnectionMaxIdleMs { get; set; }
Property Value
DefaultApiTimeoutMs
Manages DEFAULT_API_TIMEOUT_MS_CONFIG
public long DefaultApiTimeoutMs { get; set; }
Property Value
DefaultListKeySerdeInnerClass
public Class DefaultListKeySerdeInnerClass { get; set; }
Property Value
DefaultListKeySerdeTypeClass
public Class DefaultListKeySerdeTypeClass { get; set; }
Property Value
DefaultListValueSerdeInnerClass
public Class DefaultListValueSerdeInnerClass { get; set; }
Property Value
DefaultListValueSerdeTypeClass
public Class DefaultListValueSerdeTypeClass { get; set; }
Property Value
EnableMetricsPush
Manages ENABLE_METRICS_PUSH_CONFIG
public bool EnableMetricsPush { get; set; }
Property Value
GroupId
Manages GROUP_ID_CONFIG
public string GroupId { get; set; }
Property Value
GroupInstanceId
Manages GROUP_INSTANCE_ID_CONFIG
public string GroupInstanceId { get; set; }
Property Value
HeartbeatIntervalMs
Manages HEARTBEAT_INTERVAL_MS_CONFIG
public int HeartbeatIntervalMs { get; set; }
Property Value
MaxPollIntervalMs
Manages MAX_POLL_INTERVAL_MS_CONFIG
public int MaxPollIntervalMs { get; set; }
Property Value
MetadataMaxAge
Manages METADATA_MAX_AGE_CONFIG
public long MetadataMaxAge { get; set; }
Property Value
MetricNumSample
Manages METRICS_NUM_SAMPLES_CONFIG
public int MetricNumSample { get; set; }
Property Value
MetricRecordingLevel
Manages METRICS_RECORDING_LEVEL_CONFIG
public Sensor.RecordingLevel MetricRecordingLevel { get; set; }
Property Value
MetricReporterClasses
Manages METRIC_REPORTER_CLASSES_CONFIG
public List<Class> MetricReporterClasses { get; set; }
Property Value
MetricSampleWindowMs
Manages METRICS_SAMPLE_WINDOW_MS_CONFIG
public long MetricSampleWindowMs { get; set; }
Property Value
RebalanceTimeoutMs
Manages REBALANCE_TIMEOUT_MS_CONFIG
public int RebalanceTimeoutMs { get; set; }
Property Value
ReceiveBuffer
Manages RECEIVE_BUFFER_CONFIG
public int ReceiveBuffer { get; set; }
Property Value
ReconnectBackoffMaxMs
Manages RECONNECT_BACKOFF_MAX_MS_CONFIG
public long ReconnectBackoffMaxMs { get; set; }
Property Value
ReconnectBackoffMs
Manages RECONNECT_BACKOFF_MS_CONFIG
public long ReconnectBackoffMs { get; set; }
Property Value
RequestTimeoutMs
Manages REQUEST_TIMEOUT_MS_CONFIG
public int RequestTimeoutMs { get; set; }
Property Value
Retries
Manages RETRIES_CONFIG
public int Retries { get; set; }
Property Value
RetryBackoffMaxMs
Manages RETRY_BACKOFF_MAX_MS_CONFIG
public long RetryBackoffMaxMs { get; set; }
Property Value
RetryBackoffMs
Manages RETRY_BACKOFF_MS_CONFIG
public long RetryBackoffMs { get; set; }
Property Value
SecurityProtocol
Manages SECURITY_PROTOCOL_CONFIG
public string SecurityProtocol { get; set; }
Property Value
SendBuffer
Manages SEND_BUFFER_CONFIG
public int SendBuffer { get; set; }
Property Value
SessionTimeoutMs
Manages SESSION_TIMEOUT_MS_CONFIG
public int SessionTimeoutMs { get; set; }
Property Value
SocketConnectionSetupTimeoutMaxMs
public long SocketConnectionSetupTimeoutMaxMs { get; set; }
Property Value
SocketConnectionSetupTimeoutMs
public long SocketConnectionSetupTimeoutMs { get; set; }
Property Value
Methods
WithBootstrapServers(string)
Manages BOOTSTRAP_SERVERS_CONFIG
public T WithBootstrapServers(string bootstrapServers)
Parameters
bootstrapServers
string
Returns
- T
WithClientDnsLookup(string)
Manages CLIENT_DNS_LOOKUP_CONFIG
public T WithClientDnsLookup(string clientDnsLookup)
Parameters
clientDnsLookup
string
Returns
- T
WithClientId(string)
Manages CLIENT_ID_CONFIG
public T WithClientId(string clientId)
Parameters
clientId
string
Returns
- T
WithClientRack(string)
Manages CLIENT_RACK_CONFIG
public T WithClientRack(string clientRack)
Parameters
clientRack
string
Returns
- T
WithConnectionMaxIdleMs(long)
Manages CONNECTIONS_MAX_IDLE_MS_CONFIG
public T WithConnectionMaxIdleMs(long connectionMaxIdleMs)
Parameters
connectionMaxIdleMs
long
Returns
- T
WithDefaultApiTimeoutMs(long)
Manages DEFAULT_API_TIMEOUT_MS_CONFIG
public T WithDefaultApiTimeoutMs(long defaultApiTimeoutMs)
Parameters
defaultApiTimeoutMs
long
Returns
- T
WithDefaultListKeySerdeInnerClass(Class)
public T WithDefaultListKeySerdeInnerClass(Class defaultListKeySerdeInnerClass)
Parameters
defaultListKeySerdeInnerClass
Class
Returns
- T
WithDefaultListKeySerdeTypeClass(Class)
public T WithDefaultListKeySerdeTypeClass(Class defaultListKeySerdeTypeClass)
Parameters
defaultListKeySerdeTypeClass
Class
Returns
- T
WithDefaultListValueSerdeInnerClass(Class)
public T WithDefaultListValueSerdeInnerClass(Class defaultListValueSerdeInnerClass)
Parameters
defaultListValueSerdeInnerClass
Class
Returns
- T
WithDefaultListValueSerdeTypeClass(Class)
public T WithDefaultListValueSerdeTypeClass(Class defaultListValueSerdeTypeClass)
Parameters
defaultListValueSerdeTypeClass
Class
Returns
- T
WithEnableMetricsPush(bool)
Manages ENABLE_METRICS_PUSH_CONFIG
public T WithEnableMetricsPush(bool enableMetricsPush)
Parameters
enableMetricsPush
bool
Returns
- T
WithGroupId(string)
Manages GROUP_ID_CONFIG
public T WithGroupId(string groupId)
Parameters
groupId
string
Returns
- T
WithGroupInstanceId(string)
Manages GROUP_INSTANCE_ID_CONFIG
public T WithGroupInstanceId(string groupInstanceId)
Parameters
groupInstanceId
string
Returns
- T
WithHeartbeatIntervalMs(int)
Manages HEARTBEAT_INTERVAL_MS_CONFIG
public T WithHeartbeatIntervalMs(int heartbeatIntervalMs)
Parameters
heartbeatIntervalMs
int
Returns
- T
WithMaxPollIntervalMs(int)
Manages MAX_POLL_INTERVAL_MS_CONFIG
public T WithMaxPollIntervalMs(int maxPollIntervalMs)
Parameters
maxPollIntervalMs
int
Returns
- T
WithMetadataMaxAge(long)
Manages METADATA_MAX_AGE_CONFIG
public T WithMetadataMaxAge(long metadataMaxAge)
Parameters
metadataMaxAge
long
Returns
- T
WithMetricNumSample(int)
Manages METRICS_NUM_SAMPLES_CONFIG
public T WithMetricNumSample(int metricNumSample)
Parameters
metricNumSample
int
Returns
- T
WithMetricRecordingLevel(RecordingLevel)
Manages METRICS_RECORDING_LEVEL_CONFIG
public T WithMetricRecordingLevel(Sensor.RecordingLevel metricRecordingLevel)
Parameters
metricRecordingLevel
Sensor.RecordingLevel
Returns
- T
WithMetricReporterClasses(List<Class>)
Manages METRIC_REPORTER_CLASSES_CONFIG
public T WithMetricReporterClasses(List<Class> metricReporterClasses)
Parameters
Returns
- T
WithMetricSampleWindowMs(long)
Manages METRICS_SAMPLE_WINDOW_MS_CONFIG
public T WithMetricSampleWindowMs(long metricSampleWindowMs)
Parameters
metricSampleWindowMs
long
Returns
- T
WithRebalanceTimeoutMs(int)
Manages REBALANCE_TIMEOUT_MS_CONFIG
public T WithRebalanceTimeoutMs(int rebalanceTimeoutMs)
Parameters
rebalanceTimeoutMs
int
Returns
- T
WithReceiveBuffer(int)
Manages RECEIVE_BUFFER_CONFIG
public T WithReceiveBuffer(int receiveBuffer)
Parameters
receiveBuffer
int
Returns
- T
WithReconnectBackoffMaxMs(long)
Manages RECONNECT_BACKOFF_MAX_MS_CONFIG
public T WithReconnectBackoffMaxMs(long reconnectBackoffMaxMs)
Parameters
reconnectBackoffMaxMs
long
Returns
- T
WithReconnectBackoffMs(long)
Manages RECONNECT_BACKOFF_MS_CONFIG
public T WithReconnectBackoffMs(long reconnectBackoffMs)
Parameters
reconnectBackoffMs
long
Returns
- T
WithRequestTimeoutMs(int)
Manages REQUEST_TIMEOUT_MS_CONFIG
public T WithRequestTimeoutMs(int requestTimeoutMs)
Parameters
requestTimeoutMs
int
Returns
- T
WithRetries(int)
Manages RETRIES_CONFIG
public T WithRetries(int retries)
Parameters
retries
int
Returns
- T
WithRetryBackoffMaxMs(long)
Manages RETRY_BACKOFF_MAX_MS_CONFIG
public T WithRetryBackoffMaxMs(long retryBackoffMaxMs)
Parameters
retryBackoffMaxMs
long
Returns
- T
WithRetryBackoffMs(long)
Manages RETRY_BACKOFF_MS_CONFIG
public T WithRetryBackoffMs(long retryBackoffMs)
Parameters
retryBackoffMs
long
Returns
- T
WithSecurityProtocol(string)
Manages SECURITY_PROTOCOL_CONFIG
public T WithSecurityProtocol(string securityProtocol)
Parameters
securityProtocol
string
Returns
- T
WithSendBuffer(int)
Manages SEND_BUFFER_CONFIG
public T WithSendBuffer(int sendBuffer)
Parameters
sendBuffer
int
Returns
- T
WithSessionTimeoutMs(int)
Manages SESSION_TIMEOUT_MS_CONFIG
public T WithSessionTimeoutMs(int sessionTimeoutMs)
Parameters
sessionTimeoutMs
int
Returns
- T
WithSocketConnectionSetupTimeoutMaxMs(long)
public T WithSocketConnectionSetupTimeoutMaxMs(long socketConnectionSetupTimeoutMaxMs)
Parameters
socketConnectionSetupTimeoutMaxMs
long
Returns
- T
WithSocketConnectionSetupTimeoutMs(long)
public T WithSocketConnectionSetupTimeoutMs(long socketConnectionSetupTimeoutMs)
Parameters
socketConnectionSetupTimeoutMs
long
Returns
- T