Table of Contents

Class CommonClientConfigsBuilder<T>

Namespace
MASES.KNet
Assembly
MASES.KNet.dll

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

public string BootstrapServers { get; set; }

Property Value

string

ClientDnsLookup

public string ClientDnsLookup { get; set; }

Property Value

string

ClientId

public string ClientId { get; set; }

Property Value

string

ClientRack

public string ClientRack { get; set; }

Property Value

string

ConnectionMaxIdleMs

public long ConnectionMaxIdleMs { get; set; }

Property Value

long

DefaultApiTimeoutMs

public long DefaultApiTimeoutMs { get; set; }

Property Value

long

DefaultListKeySerdeInnerClass

public Class DefaultListKeySerdeInnerClass { get; set; }

Property Value

Class

DefaultListKeySerdeTypeClass

public Class DefaultListKeySerdeTypeClass { get; set; }

Property Value

Class

DefaultListValueSerdeInnerClass

public Class DefaultListValueSerdeInnerClass { get; set; }

Property Value

Class

DefaultListValueSerdeTypeClass

public Class DefaultListValueSerdeTypeClass { get; set; }

Property Value

Class

EnableMetricsPush

public bool EnableMetricsPush { get; set; }

Property Value

bool

GroupId

public string GroupId { get; set; }

Property Value

string

GroupInstanceId

public string GroupInstanceId { get; set; }

Property Value

string

HeartbeatIntervalMs

public int HeartbeatIntervalMs { get; set; }

Property Value

int

MaxPollIntervalMs

public int MaxPollIntervalMs { get; set; }

Property Value

int

MetadataMaxAge

public long MetadataMaxAge { get; set; }

Property Value

long

MetricNumSample

public int MetricNumSample { get; set; }

Property Value

int

MetricRecordingLevel

public Sensor.RecordingLevel MetricRecordingLevel { get; set; }

Property Value

Sensor.RecordingLevel

MetricReporterClasses

public List<Class> MetricReporterClasses { get; set; }

Property Value

List<Class>

MetricSampleWindowMs

public long MetricSampleWindowMs { get; set; }

Property Value

long

RebalanceTimeoutMs

public int RebalanceTimeoutMs { get; set; }

Property Value

int

ReceiveBuffer

public int ReceiveBuffer { get; set; }

Property Value

int

ReconnectBackoffMaxMs

public long ReconnectBackoffMaxMs { get; set; }

Property Value

long

ReconnectBackoffMs

public long ReconnectBackoffMs { get; set; }

Property Value

long

RequestTimeoutMs

public int RequestTimeoutMs { get; set; }

Property Value

int

Retries

public int Retries { get; set; }

Property Value

int

RetryBackoffMaxMs

public long RetryBackoffMaxMs { get; set; }

Property Value

long

RetryBackoffMs

public long RetryBackoffMs { get; set; }

Property Value

long

SecurityProtocol

public string SecurityProtocol { get; set; }

Property Value

string

SendBuffer

public int SendBuffer { get; set; }

Property Value

int

SessionTimeoutMs

public int SessionTimeoutMs { get; set; }

Property Value

int

SocketConnectionSetupTimeoutMaxMs

public long SocketConnectionSetupTimeoutMaxMs { get; set; }

Property Value

long

SocketConnectionSetupTimeoutMs

public long SocketConnectionSetupTimeoutMs { get; set; }

Property Value

long

Methods

WithBootstrapServers(string)

public T WithBootstrapServers(string bootstrapServers)

Parameters

bootstrapServers string

Returns

T

WithClientDnsLookup(string)

public T WithClientDnsLookup(string clientDnsLookup)

Parameters

clientDnsLookup string

Returns

T

WithClientId(string)

public T WithClientId(string clientId)

Parameters

clientId string

Returns

T

WithClientRack(string)

public T WithClientRack(string clientRack)

Parameters

clientRack string

Returns

T

WithConnectionMaxIdleMs(long)

public T WithConnectionMaxIdleMs(long connectionMaxIdleMs)

Parameters

connectionMaxIdleMs long

Returns

T

WithDefaultApiTimeoutMs(long)

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)

public T WithEnableMetricsPush(bool enableMetricsPush)

Parameters

enableMetricsPush bool

Returns

T

WithGroupId(string)

public T WithGroupId(string groupId)

Parameters

groupId string

Returns

T

WithGroupInstanceId(string)

public T WithGroupInstanceId(string groupInstanceId)

Parameters

groupInstanceId string

Returns

T

WithHeartbeatIntervalMs(int)

public T WithHeartbeatIntervalMs(int heartbeatIntervalMs)

Parameters

heartbeatIntervalMs int

Returns

T

WithMaxPollIntervalMs(int)

public T WithMaxPollIntervalMs(int maxPollIntervalMs)

Parameters

maxPollIntervalMs int

Returns

T

WithMetadataMaxAge(long)

public T WithMetadataMaxAge(long metadataMaxAge)

Parameters

metadataMaxAge long

Returns

T

WithMetricNumSample(int)

public T WithMetricNumSample(int metricNumSample)

Parameters

metricNumSample int

Returns

T

WithMetricRecordingLevel(RecordingLevel)

public T WithMetricRecordingLevel(Sensor.RecordingLevel metricRecordingLevel)

Parameters

metricRecordingLevel Sensor.RecordingLevel

Returns

T

WithMetricReporterClasses(List<Class>)

public T WithMetricReporterClasses(List<Class> metricReporterClasses)

Parameters

metricReporterClasses List<Class>

Returns

T

WithMetricSampleWindowMs(long)

public T WithMetricSampleWindowMs(long metricSampleWindowMs)

Parameters

metricSampleWindowMs long

Returns

T

WithRebalanceTimeoutMs(int)

public T WithRebalanceTimeoutMs(int rebalanceTimeoutMs)

Parameters

rebalanceTimeoutMs int

Returns

T

WithReceiveBuffer(int)

public T WithReceiveBuffer(int receiveBuffer)

Parameters

receiveBuffer int

Returns

T

WithReconnectBackoffMaxMs(long)

public T WithReconnectBackoffMaxMs(long reconnectBackoffMaxMs)

Parameters

reconnectBackoffMaxMs long

Returns

T

WithReconnectBackoffMs(long)

public T WithReconnectBackoffMs(long reconnectBackoffMs)

Parameters

reconnectBackoffMs long

Returns

T

WithRequestTimeoutMs(int)

public T WithRequestTimeoutMs(int requestTimeoutMs)

Parameters

requestTimeoutMs int

Returns

T

WithRetries(int)

public T WithRetries(int retries)

Parameters

retries int

Returns

T

WithRetryBackoffMaxMs(long)

public T WithRetryBackoffMaxMs(long retryBackoffMaxMs)

Parameters

retryBackoffMaxMs long

Returns

T

WithRetryBackoffMs(long)

public T WithRetryBackoffMs(long retryBackoffMs)

Parameters

retryBackoffMs long

Returns

T

WithSecurityProtocol(string)

public T WithSecurityProtocol(string securityProtocol)

Parameters

securityProtocol string

Returns

T

WithSendBuffer(int)

public T WithSendBuffer(int sendBuffer)

Parameters

sendBuffer int

Returns

T

WithSessionTimeoutMs(int)

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