Class ConsumerConfigBuilder

Namespace

MASES.KNet.Consumer

Assembly

MASES.KNet.dll

Builder for ConsumerConfig

public class ConsumerConfigBuilder : CommonClientConfigsBuilder<ConsumerConfigBuilder>, INotifyPropertyChanged, IGenericSerDesFactory, IDisposable

Inheritance

object

GenericConfigBuilder<ConsumerConfigBuilder>

CommonClientConfigsBuilder<ConsumerConfigBuilder>

ConsumerConfigBuilder

Implements

INotifyPropertyChanged

IGenericSerDesFactory

IDisposable

Inherited Members

CommonClientConfigsBuilder<ConsumerConfigBuilder>.BootstrapServers

CommonClientConfigsBuilder<ConsumerConfigBuilder>.WithBootstrapServers(string)

CommonClientConfigsBuilder<ConsumerConfigBuilder>.ClientDnsLookup

CommonClientConfigsBuilder<ConsumerConfigBuilder>.WithClientDnsLookup(string)

CommonClientConfigsBuilder<ConsumerConfigBuilder>.MetadataMaxAge

CommonClientConfigsBuilder<ConsumerConfigBuilder>.WithMetadataMaxAge(long)

CommonClientConfigsBuilder<ConsumerConfigBuilder>.SendBuffer

CommonClientConfigsBuilder<ConsumerConfigBuilder>.WithSendBuffer(int)

CommonClientConfigsBuilder<ConsumerConfigBuilder>.ReceiveBuffer

CommonClientConfigsBuilder<ConsumerConfigBuilder>.WithReceiveBuffer(int)

CommonClientConfigsBuilder<ConsumerConfigBuilder>.ClientId

CommonClientConfigsBuilder<ConsumerConfigBuilder>.WithClientId(string)

CommonClientConfigsBuilder<ConsumerConfigBuilder>.ClientRack

CommonClientConfigsBuilder<ConsumerConfigBuilder>.WithClientRack(string)

CommonClientConfigsBuilder<ConsumerConfigBuilder>.ReconnectBackoffMs

CommonClientConfigsBuilder<ConsumerConfigBuilder>.WithReconnectBackoffMs(long)

CommonClientConfigsBuilder<ConsumerConfigBuilder>.ReconnectBackoffMaxMs

CommonClientConfigsBuilder<ConsumerConfigBuilder>.WithReconnectBackoffMaxMs(long)

CommonClientConfigsBuilder<ConsumerConfigBuilder>.Retries

CommonClientConfigsBuilder<ConsumerConfigBuilder>.WithRetries(int)

CommonClientConfigsBuilder<ConsumerConfigBuilder>.RetryBackoffMaxMs

CommonClientConfigsBuilder<ConsumerConfigBuilder>.WithRetryBackoffMaxMs(long)

CommonClientConfigsBuilder<ConsumerConfigBuilder>.RetryBackoffMs

CommonClientConfigsBuilder<ConsumerConfigBuilder>.WithRetryBackoffMs(long)

CommonClientConfigsBuilder<ConsumerConfigBuilder>.MetricSampleWindowMs

CommonClientConfigsBuilder<ConsumerConfigBuilder>.WithMetricSampleWindowMs(long)

CommonClientConfigsBuilder<ConsumerConfigBuilder>.MetricNumSample

CommonClientConfigsBuilder<ConsumerConfigBuilder>.WithMetricNumSample(int)

CommonClientConfigsBuilder<ConsumerConfigBuilder>.MetricRecordingLevel

CommonClientConfigsBuilder<ConsumerConfigBuilder>.WithMetricRecordingLevel(Sensor.RecordingLevel)

CommonClientConfigsBuilder<ConsumerConfigBuilder>.MetricReporterClasses

CommonClientConfigsBuilder<ConsumerConfigBuilder>.WithMetricReporterClasses(List<Class>)

CommonClientConfigsBuilder<ConsumerConfigBuilder>.SecurityProtocol

CommonClientConfigsBuilder<ConsumerConfigBuilder>.WithSecurityProtocol(string)

CommonClientConfigsBuilder<ConsumerConfigBuilder>.SocketConnectionSetupTimeoutMs

CommonClientConfigsBuilder<ConsumerConfigBuilder>.WithSocketConnectionSetupTimeoutMs(long)

CommonClientConfigsBuilder<ConsumerConfigBuilder>.SocketConnectionSetupTimeoutMaxMs

CommonClientConfigsBuilder<ConsumerConfigBuilder>.WithSocketConnectionSetupTimeoutMaxMs(long)

CommonClientConfigsBuilder<ConsumerConfigBuilder>.ConnectionMaxIdleMs

CommonClientConfigsBuilder<ConsumerConfigBuilder>.WithConnectionMaxIdleMs(long)

CommonClientConfigsBuilder<ConsumerConfigBuilder>.RequestTimeoutMs

CommonClientConfigsBuilder<ConsumerConfigBuilder>.WithRequestTimeoutMs(int)

CommonClientConfigsBuilder<ConsumerConfigBuilder>.DefaultListKeySerdeInnerClass

CommonClientConfigsBuilder<ConsumerConfigBuilder>.WithDefaultListKeySerdeInnerClass(Class)

CommonClientConfigsBuilder<ConsumerConfigBuilder>.DefaultListValueSerdeInnerClass

CommonClientConfigsBuilder<ConsumerConfigBuilder>.WithDefaultListValueSerdeInnerClass(Class)

CommonClientConfigsBuilder<ConsumerConfigBuilder>.DefaultListKeySerdeTypeClass

CommonClientConfigsBuilder<ConsumerConfigBuilder>.WithDefaultListKeySerdeTypeClass(Class)

CommonClientConfigsBuilder<ConsumerConfigBuilder>.DefaultListValueSerdeTypeClass

CommonClientConfigsBuilder<ConsumerConfigBuilder>.WithDefaultListValueSerdeTypeClass(Class)

CommonClientConfigsBuilder<ConsumerConfigBuilder>.EnableMetricsPush

CommonClientConfigsBuilder<ConsumerConfigBuilder>.WithEnableMetricsPush(bool)

CommonClientConfigsBuilder<ConsumerConfigBuilder>.GroupId

CommonClientConfigsBuilder<ConsumerConfigBuilder>.WithGroupId(string)

CommonClientConfigsBuilder<ConsumerConfigBuilder>.GroupInstanceId

CommonClientConfigsBuilder<ConsumerConfigBuilder>.WithGroupInstanceId(string)

CommonClientConfigsBuilder<ConsumerConfigBuilder>.MaxPollIntervalMs

CommonClientConfigsBuilder<ConsumerConfigBuilder>.WithMaxPollIntervalMs(int)

CommonClientConfigsBuilder<ConsumerConfigBuilder>.RebalanceTimeoutMs

CommonClientConfigsBuilder<ConsumerConfigBuilder>.WithRebalanceTimeoutMs(int)

CommonClientConfigsBuilder<ConsumerConfigBuilder>.SessionTimeoutMs

CommonClientConfigsBuilder<ConsumerConfigBuilder>.WithSessionTimeoutMs(int)

CommonClientConfigsBuilder<ConsumerConfigBuilder>.HeartbeatIntervalMs

CommonClientConfigsBuilder<ConsumerConfigBuilder>.WithHeartbeatIntervalMs(int)

CommonClientConfigsBuilder<ConsumerConfigBuilder>.DefaultApiTimeoutMs

CommonClientConfigsBuilder<ConsumerConfigBuilder>.WithDefaultApiTimeoutMs(long)

GenericConfigBuilder<ConsumerConfigBuilder>.Create()

GenericConfigBuilder<ConsumerConfigBuilder>.CreateFrom(ConsumerConfigBuilder)

GenericConfigBuilder<ConsumerConfigBuilder>.PropertyChanged

GenericConfigBuilder<ConsumerConfigBuilder>.ExistProperty(string)

GenericConfigBuilder<ConsumerConfigBuilder>.GetProperty<TData>(string)

GenericConfigBuilder<ConsumerConfigBuilder>.SetProperty(string, object)

GenericConfigBuilder<ConsumerConfigBuilder>.Clone()

GenericConfigBuilder<ConsumerConfigBuilder>.ToProperties()

GenericConfigBuilder<ConsumerConfigBuilder>.ToMap()

GenericConfigBuilder<ConsumerConfigBuilder>.AutoSelectBuffered

GenericConfigBuilder<ConsumerConfigBuilder>.KeySerDesSelector

GenericConfigBuilder<ConsumerConfigBuilder>.ValueSerDesSelector

GenericConfigBuilder<ConsumerConfigBuilder>.BuildKeySerDes<TKey, TJVMTKey>()

GenericConfigBuilder<ConsumerConfigBuilder>.BuildValueSerDes<TValue, TJVMTValue>()

GenericConfigBuilder<ConsumerConfigBuilder>.Clear()

GenericConfigBuilder<ConsumerConfigBuilder>.Dispose()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

Extension Methods

ConsumerConfigBuilderExtensions.CanApplyBasicDeserializer<T>(ConsumerConfigBuilder)

ConsumerConfigBuilderExtensions.WithKeyDeserializerClass(ConsumerConfigBuilder, Type)

ConsumerConfigBuilderExtensions.WithKeyDeserializerClass<T>(ConsumerConfigBuilder)

ConsumerConfigBuilderExtensions.WithValueDeserializerClass(ConsumerConfigBuilder, Type)

ConsumerConfigBuilderExtensions.WithValueDeserializerClass<T>(ConsumerConfigBuilder)

Properties

AllowAutoCreateTopics

Manages ALLOW_AUTO_CREATE_TOPICS_CONFIG

public bool AllowAutoCreateTopics { get; set; }

Property Value

bool

AutoCommitIntervalMs

Manages AUTO_COMMIT_INTERVAL_MS_CONFIG

public int AutoCommitIntervalMs { get; set; }

Property Value

int

AutoOffsetReset

Manages AUTO_OFFSET_RESET_CONFIG

public ConsumerConfigBuilder.AutoOffsetResetTypes AutoOffsetReset { get; set; }

Property Value

ConsumerConfigBuilder.AutoOffsetResetTypes

CheckCrcs

Manages CHECK_CRCS_CONFIG

public bool CheckCrcs { get; set; }

Property Value

bool

EnableAutoCommit

Manages ENABLE_AUTO_COMMIT_CONFIG

public bool EnableAutoCommit { get; set; }

Property Value

bool

ExcludeInternalTopics

Manages EXCLUDE_INTERNAL_TOPICS_CONFIG

public bool ExcludeInternalTopics { get; set; }

Property Value

bool

FetchMaxBytes

Manages FETCH_MAX_BYTES_CONFIG

public int FetchMaxBytes { get; set; }

Property Value

int

FetchMaxWaitMs

Manages FETCH_MAX_WAIT_MS_CONFIG

public int FetchMaxWaitMs { get; set; }

Property Value

int

FetchMinBytes

Manages FETCH_MIN_BYTES_CONFIG

public int FetchMinBytes { get; set; }

Property Value

int

GroupProtocol

Manages GROUP_PROTOCOL_CONFIG

public string GroupProtocol { get; set; }

Property Value

string

GroupRemoteAssignor

Manages GROUP_REMOTE_ASSIGNOR_CONFIG

public string GroupRemoteAssignor { get; set; }

Property Value

string

InterceptorClasses

Manages INTERCEPTOR_CLASSES_CONFIG

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

Property Value

List<Class>

IsolationLevel

Manages ISOLATION_LEVEL_CONFIG

public IsolationLevel IsolationLevel { get; set; }

Property Value

IsolationLevel

KeyDeserializerClass

Manages KEY_DESERIALIZER_CLASS_CONFIG

public string KeyDeserializerClass { get; set; }

Property Value

string

MaxPartitionFetchBytes

Manages MAX_PARTITION_FETCH_BYTES_CONFIG

public int MaxPartitionFetchBytes { get; set; }

Property Value

int

MaxPollRecords

Manages MAX_POLL_RECORDS_CONFIG

public int MaxPollRecords { get; set; }

Property Value

int

PartitionAssignmentStrategy

Manages PARTITION_ASSIGNMENT_STRATEGY_CONFIG

public string PartitionAssignmentStrategy { get; set; }

Property Value

string

SecurityProviders

Manages SECURITY_PROVIDERS_CONFIG

public string SecurityProviders { get; set; }

Property Value

string

ValueDeserializerClass

Manages VALUE_DESERIALIZER_CLASS_CONFIG

public string ValueDeserializerClass { get; set; }

Property Value

string

Methods

WithAllowAutoCreateTopics(bool)

Manages ALLOW_AUTO_CREATE_TOPICS_CONFIG

public ConsumerConfigBuilder WithAllowAutoCreateTopics(bool allowAutoCreateTopics)

Parameters

allowAutoCreateTopics bool

Returns

ConsumerConfigBuilder

WithAutoCommitIntervalMs(int)

Manages AUTO_COMMIT_INTERVAL_MS_CONFIG

public ConsumerConfigBuilder WithAutoCommitIntervalMs(int autoCommitIntervalMs)

Parameters

autoCommitIntervalMs int

Returns

ConsumerConfigBuilder

WithAutoOffsetReset(AutoOffsetResetTypes)

Manages AUTO_OFFSET_RESET_CONFIG

public ConsumerConfigBuilder WithAutoOffsetReset(ConsumerConfigBuilder.AutoOffsetResetTypes autoOffsetReset)

Parameters

autoOffsetReset ConsumerConfigBuilder.AutoOffsetResetTypes

Returns

ConsumerConfigBuilder

WithCheckCrcs(bool)

Manages CHECK_CRCS_CONFIG

public ConsumerConfigBuilder WithCheckCrcs(bool checkCrcs)

Parameters

checkCrcs bool

Returns

ConsumerConfigBuilder

WithEnableAutoCommit(bool)

Manages ENABLE_AUTO_COMMIT_CONFIG

public ConsumerConfigBuilder WithEnableAutoCommit(bool enableAutoCommit)

Parameters

enableAutoCommit bool

Returns

ConsumerConfigBuilder

WithExcludeInternalTopics(bool)

Manages EXCLUDE_INTERNAL_TOPICS_CONFIG

public ConsumerConfigBuilder WithExcludeInternalTopics(bool excludeInternalTopics)

Parameters

excludeInternalTopics bool

Returns

ConsumerConfigBuilder

WithFetchMaxBytes(int)

Manages FETCH_MAX_BYTES_CONFIG

public ConsumerConfigBuilder WithFetchMaxBytes(int fetchMaxBytes)

Parameters

fetchMaxBytes int

Returns

ConsumerConfigBuilder

WithFetchMaxWaitMs(int)

Manages FETCH_MAX_WAIT_MS_CONFIG

public ConsumerConfigBuilder WithFetchMaxWaitMs(int fetchMaxWaitMs)

Parameters

fetchMaxWaitMs int

Returns

ConsumerConfigBuilder

WithFetchMinBytes(int)

Manages FETCH_MIN_BYTES_CONFIG

public ConsumerConfigBuilder WithFetchMinBytes(int fetchMinBytes)

Parameters

fetchMinBytes int

Returns

ConsumerConfigBuilder

WithGroupProtocol(string)

Manages GROUP_PROTOCOL_CONFIG

public ConsumerConfigBuilder WithGroupProtocol(string groupProtocol)

Parameters

groupProtocol string

Returns

ConsumerConfigBuilder

WithGroupRemoteAssignor(string)

Manages GROUP_REMOTE_ASSIGNOR_CONFIG

public ConsumerConfigBuilder WithGroupRemoteAssignor(string groupRemoteAssignor)

Parameters

groupRemoteAssignor string

Returns

ConsumerConfigBuilder

WithInterceptorClasses(List<Class>)

Manages INTERCEPTOR_CLASSES_CONFIG

public ConsumerConfigBuilder WithInterceptorClasses(List<Class> interceptorClasses)

Parameters

interceptorClasses List<Class>

Returns

ConsumerConfigBuilder

WithIsolationLevel(IsolationLevel)

Manages ISOLATION_LEVEL_CONFIG

public ConsumerConfigBuilder WithIsolationLevel(IsolationLevel isolationLevel)

Parameters

isolationLevel IsolationLevel

Returns

ConsumerConfigBuilder

WithKeyDeserializerClass(string)

Manages KEY_DESERIALIZER_CLASS_CONFIG

public ConsumerConfigBuilder WithKeyDeserializerClass(string keyDeserializerClass)

Parameters

keyDeserializerClass string

Returns

ConsumerConfigBuilder

WithMaxPartitionFetchBytes(int)

Manages MAX_PARTITION_FETCH_BYTES_CONFIG

public ConsumerConfigBuilder WithMaxPartitionFetchBytes(int maxPartitionFetchBytes)

Parameters

maxPartitionFetchBytes int

Returns

ConsumerConfigBuilder

WithMaxPollRecords(int)

Manages MAX_POLL_RECORDS_CONFIG

public ConsumerConfigBuilder WithMaxPollRecords(int maxPollRecords)

Parameters

maxPollRecords int

Returns

ConsumerConfigBuilder

WithPartitionAssignmentStrategy(string)

Manages PARTITION_ASSIGNMENT_STRATEGY_CONFIG

public ConsumerConfigBuilder WithPartitionAssignmentStrategy(string partitionAssignmentStrategy)

Parameters

partitionAssignmentStrategy string

Returns

ConsumerConfigBuilder

WithSecurityProviders(string)

Manages SECURITY_PROVIDERS_CONFIG

public ConsumerConfigBuilder WithSecurityProviders(string securityProviders)

Parameters

securityProviders string

Returns

ConsumerConfigBuilder

WithValueDeserializerClass(string)

Manages VALUE_DESERIALIZER_CLASS_CONFIG

public ConsumerConfigBuilder WithValueDeserializerClass(string valueDeserializerClass)

Parameters

valueDeserializerClass string

Returns

ConsumerConfigBuilder