Table of Contents

Class StreamsConfigBuilder

Namespace
MASES.KNet.Streams
Assembly
MASES.KNet.dll

Builder for StreamsConfig

public class StreamsConfigBuilder : CommonClientConfigsBuilder<StreamsConfigBuilder>, INotifyPropertyChanged, IGenericSerDesFactory, IDisposable, IEnumerable<KeyValuePair<string, object>>, IEnumerable
Inheritance
StreamsConfigBuilder
Implements
Inherited Members

Properties

AcceptableRecoveryLag

Manages ACCEPTABLE_RECOVERY_LAG_CONFIG

public long AcceptableRecoveryLag { get; set; }

Property Value

long

AllowOsGroupWriteAccess

Manages ALLOW_OS_GROUP_WRITE_ACCESS_CONFIG

public bool AllowOsGroupWriteAccess { get; set; }

Property Value

bool

ApplicationId

Manages APPLICATION_ID_CONFIG

public string ApplicationId { get; set; }

Property Value

string

ApplicationServer

Manages APPLICATION_SERVER_CONFIG

public string ApplicationServer { get; set; }

Property Value

string

BufferedRecordsPerPartition

Manages BUFFERED_RECORDS_PER_PARTITION_CONFIG

public int BufferedRecordsPerPartition { get; set; }

Property Value

int

BuiltInMetricsVersion

Manages BUILT_IN_METRICS_VERSION_CONFIG

public string BuiltInMetricsVersion { get; set; }

Property Value

string

CommitIntervalMs

Manages COMMIT_INTERVAL_MS_CONFIG

public long CommitIntervalMs { get; set; }

Property Value

long

DSLStoreSuppliersClass

Manages DSL_STORE_SUPPLIERS_CLASS_CONFIG: use ROCKS_DB or IN_MEMORY

public Class DSLStoreSuppliersClass { get; set; }

Property Value

Class

DefaultClientSupplier

Manages DEFAULT_CLIENT_SUPPLIER_CONFIG

public Class DefaultClientSupplier { get; set; }

Property Value

Class

DefaultGroupProtocol

Manages DEFAULT_GROUP_PROTOCOL

public string DefaultGroupProtocol { get; set; }

Property Value

string

DefaultKeySerdeClass

Manages DEFAULT_KEY_SERDE_CLASS_CONFIG

public Class DefaultKeySerdeClass { get; set; }

Property Value

Class

DefaultTimestampExtractorClass

Manages DEFAULT_TIMESTAMP_EXTRACTOR_CLASS_CONFIG

public Class DefaultTimestampExtractorClass { get; set; }

Property Value

Class

DefaultValueSerdeClass

Manages DEFAULT_VALUE_SERDE_CLASS_CONFIG

public Class DefaultValueSerdeClass { get; set; }

Property Value

Class

DeserializationExceptionHandlerClass

Manages DESERIALIZATION_EXCEPTION_HANDLER_CLASS_CONFIG

public Class DeserializationExceptionHandlerClass { get; set; }

Property Value

Class

EnsureExplicitInternalResourceNaming

Manages ENSURE_EXPLICIT_INTERNAL_RESOURCE_NAMING_CONFIG

public bool EnsureExplicitInternalResourceNaming { get; set; }

Property Value

bool

ErrorsDeadLetterQueueTopicName

Manages ERRORS_DEAD_LETTER_QUEUE_TOPIC_NAME_CONFIG

public string ErrorsDeadLetterQueueTopicName { get; set; }

Property Value

string

GroupProtocol

Manages GROUP_PROTOCOL_CONFIG

public string GroupProtocol { get; set; }

Property Value

string

LogSummaryIntervalMs

Manages LOG_SUMMARY_INTERVAL_MS_CONFIG

public long LogSummaryIntervalMs { get; set; }

Property Value

long

MaxTaskIdleMs

Manages MAX_TASK_IDLE_MS_CONFIG

public long MaxTaskIdleMs { get; set; }

Property Value

long

MaxWarmupReplicas

Manages MAX_WARMUP_REPLICAS_CONFIG

public int MaxWarmupReplicas { get; set; }

Property Value

int

NumStandByReplicas

Manages NUM_STANDBY_REPLICAS_CONFIG

public int NumStandByReplicas { get; set; }

Property Value

int

NumStreamThreads

Manages NUM_STREAM_THREADS_CONFIG

public int NumStreamThreads { get; set; }

Property Value

int

PollMs

Manages POLL_MS_CONFIG

public long PollMs { get; set; }

Property Value

long

ProbingRebalanceIntervalMs

Manages PROBING_REBALANCE_INTERVAL_MS_CONFIG

public long ProbingRebalanceIntervalMs { get; set; }

Property Value

long

ProcessingExceptionHandlerClass

Manages PROCESSING_EXCEPTION_HANDLER_CLASS_CONFIG

public Class ProcessingExceptionHandlerClass { get; set; }

Property Value

Class

ProcessingGuarantee

Manages PROCESSING_GUARANTEE_CONFIG: use AT_LEAST_ONCE or EXACTLY_ONCE_V2

public string ProcessingGuarantee { get; set; }

Property Value

string

ProcessorWrapperClass

Manages PROCESSOR_WRAPPER_CLASS_CONFIG

public Class ProcessorWrapperClass { get; set; }

Property Value

Class

ProductionExceptionHandlerClass

Manages PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIG

public Class ProductionExceptionHandlerClass { get; set; }

Property Value

Class

RackAwareAssignmentNonOverlapCost

Manages RACK_AWARE_ASSIGNMENT_NON_OVERLAP_COST_CONFIG

public int RackAwareAssignmentNonOverlapCost { get; set; }

Property Value

int

RackAwareAssignmentStrategy

Manages RACK_AWARE_ASSIGNMENT_STRATEGY_CONFIG: use RACK_AWARE_ASSIGNMENT_STRATEGY_NONE or RACK_AWARE_ASSIGNMENT_STRATEGY_MIN_TRAFFIC

public string RackAwareAssignmentStrategy { get; set; }

Property Value

string

RackAwareAssignmentTags

Manages RACK_AWARE_ASSIGNMENT_TAGS_CONFIG

public List<string> RackAwareAssignmentTags { get; set; }

Property Value

List<string>

RackAwareAssignmentTrafficCost

Manages RACK_AWARE_ASSIGNMENT_TRAFFIC_COST_CONFIG

public int RackAwareAssignmentTrafficCost { get; set; }

Property Value

int

RepartitionPurgeIntervalMs

Manages REPARTITION_PURGE_INTERVAL_MS_CONFIG

public long RepartitionPurgeIntervalMs { get; set; }

Property Value

long

ReplicationFactor

Manages REPLICATION_FACTOR_CONFIG

public int ReplicationFactor { get; set; }

Property Value

int

RocksDbConfigSetterClass

Manages ROCKSDB_CONFIG_SETTER_CLASS_CONFIG

public Class RocksDbConfigSetterClass { get; set; }

Property Value

Class

StateCleanupDelayMs

Manages STATE_CLEANUP_DELAY_MS_CONFIG

public long StateCleanupDelayMs { get; set; }

Property Value

long

StateDir

Manages STATE_DIR_CONFIG

public string StateDir { get; set; }

Property Value

string

StateStoreMaxBytesBuffering

Manages STATESTORE_CACHE_MAX_BYTES_CONFIG

public long StateStoreMaxBytesBuffering { get; set; }

Property Value

long

TaskAssignorClass

Manages TASK_ASSIGNOR_CLASS_CONFIG

public Class TaskAssignorClass { get; set; }

Property Value

Class

TaskTimeoutMs

Manages TASK_TIMEOUT_MS_CONFIG

public long TaskTimeoutMs { get; set; }

Property Value

long

TopologyOptimization

Manages TOPOLOGY_OPTIMIZATION_CONFIG: use OPTIMIZE or NO_OPTIMIZATION

public bool TopologyOptimization { get; set; }

Property Value

bool

UpgradeFrom

Manages UPGRADE_FROM_CONFIG

public string UpgradeFrom { get; set; }

Property Value

string

WindowStoreChangeLogAdditionalRetentionMs

Manages WINDOW_STORE_CHANGE_LOG_ADDITIONAL_RETENTION_MS_CONFIG

public long WindowStoreChangeLogAdditionalRetentionMs { get; set; }

Property Value

long

Methods

WithAcceptableRecoveryLag(long)

Manages ACCEPTABLE_RECOVERY_LAG_CONFIG

public StreamsConfigBuilder WithAcceptableRecoveryLag(long acceptableRecoveryLag)

Parameters

acceptableRecoveryLag long

Returns

StreamsConfigBuilder

WithAllowOsGroupWriteAccess(bool)

Manages ALLOW_OS_GROUP_WRITE_ACCESS_CONFIG

public StreamsConfigBuilder WithAllowOsGroupWriteAccess(bool allowOsGroupWriteAccess)

Parameters

allowOsGroupWriteAccess bool

Returns

StreamsConfigBuilder

WithApplicationId(string)

Manages APPLICATION_ID_CONFIG

public StreamsConfigBuilder WithApplicationId(string applicationId)

Parameters

applicationId string

Returns

StreamsConfigBuilder

WithApplicationServer(string)

Manages APPLICATION_SERVER_CONFIG

public StreamsConfigBuilder WithApplicationServer(string applicationServer)

Parameters

applicationServer string

Returns

StreamsConfigBuilder

WithBufferedRecordsPerPartition(int)

Manages BUFFERED_RECORDS_PER_PARTITION_CONFIG

public StreamsConfigBuilder WithBufferedRecordsPerPartition(int bufferedRecordsPerPartition)

Parameters

bufferedRecordsPerPartition int

Returns

StreamsConfigBuilder

WithBuiltInMetricsVersion(string)

Manages BUILT_IN_METRICS_VERSION_CONFIG

public StreamsConfigBuilder WithBuiltInMetricsVersion(string builtInMetricsVersion)

Parameters

builtInMetricsVersion string

Returns

StreamsConfigBuilder

WithCommitIntervalMs(long)

Manages COMMIT_INTERVAL_MS_CONFIG

public StreamsConfigBuilder WithCommitIntervalMs(long commitIntervalMs)

Parameters

commitIntervalMs long

Returns

StreamsConfigBuilder

WithDSLStoreSuppliersClass(Class)

Manages DSL_STORE_SUPPLIERS_CLASS_CONFIG: use ROCKS_DB or IN_MEMORY

public StreamsConfigBuilder WithDSLStoreSuppliersClass(Class dSLStoreSuppliersClass)

Parameters

dSLStoreSuppliersClass Class

Returns

StreamsConfigBuilder

WithDefaultClientSupplier(Class)

Manages DEFAULT_CLIENT_SUPPLIER_CONFIG

public StreamsConfigBuilder WithDefaultClientSupplier(Class defaultClientSupplier)

Parameters

defaultClientSupplier Class

Returns

StreamsConfigBuilder

WithDefaultGroupProtocol(string)

Manages DEFAULT_GROUP_PROTOCOL

public StreamsConfigBuilder WithDefaultGroupProtocol(string defaultGroupProtocol)

Parameters

defaultGroupProtocol string

Returns

StreamsConfigBuilder

WithDefaultKeySerdeClass(Class)

Manages DEFAULT_KEY_SERDE_CLASS_CONFIG

public StreamsConfigBuilder WithDefaultKeySerdeClass(Class defaultKeySerdeClass)

Parameters

defaultKeySerdeClass Class

Returns

StreamsConfigBuilder

WithDefaultTimestampExtractorClass(Class)

Manages DEFAULT_TIMESTAMP_EXTRACTOR_CLASS_CONFIG

public StreamsConfigBuilder WithDefaultTimestampExtractorClass(Class defaultTimestampExtractorClass)

Parameters

defaultTimestampExtractorClass Class

Returns

StreamsConfigBuilder

WithDefaultValueSerdeClass(Class)

Manages DEFAULT_VALUE_SERDE_CLASS_CONFIG

public StreamsConfigBuilder WithDefaultValueSerdeClass(Class defaultValueSerdeClass)

Parameters

defaultValueSerdeClass Class

Returns

StreamsConfigBuilder

WithDeserializationExceptionHandlerClass(Class)

Manages DESERIALIZATION_EXCEPTION_HANDLER_CLASS_CONFIG

public StreamsConfigBuilder WithDeserializationExceptionHandlerClass(Class deserializationExceptionHandlerClass)

Parameters

deserializationExceptionHandlerClass Class

Returns

StreamsConfigBuilder

WithEnsureExplicitInternalResourceNaming(bool)

Manages ENSURE_EXPLICIT_INTERNAL_RESOURCE_NAMING_CONFIG

public StreamsConfigBuilder WithEnsureExplicitInternalResourceNaming(bool ensureExplicitInternalResourceNaming)

Parameters

ensureExplicitInternalResourceNaming bool

Returns

StreamsConfigBuilder

WithErrorsDeadLetterQueueTopicName(string)

Manages ERRORS_DEAD_LETTER_QUEUE_TOPIC_NAME_CONFIG

public StreamsConfigBuilder WithErrorsDeadLetterQueueTopicName(string errorsDeadLetterQueueTopicName)

Parameters

errorsDeadLetterQueueTopicName string

Returns

StreamsConfigBuilder

WithGroupProtocol(string)

Manages GROUP_PROTOCOL_CONFIG

public StreamsConfigBuilder WithGroupProtocol(string groupProtocol)

Parameters

groupProtocol string

Returns

StreamsConfigBuilder

WithLogSummaryIntervalMs(long)

Manages LOG_SUMMARY_INTERVAL_MS_CONFIG

public StreamsConfigBuilder WithLogSummaryIntervalMs(long logSummaryIntervalMs)

Parameters

logSummaryIntervalMs long

Returns

StreamsConfigBuilder

WithMaxTaskIdleMs(long)

Manages MAX_TASK_IDLE_MS_CONFIG

public StreamsConfigBuilder WithMaxTaskIdleMs(long maxTaskIdleMs)

Parameters

maxTaskIdleMs long

Returns

StreamsConfigBuilder

WithMaxWarmupReplicas(int)

Manages MAX_WARMUP_REPLICAS_CONFIG

public StreamsConfigBuilder WithMaxWarmupReplicas(int maxWarmupReplicas)

Parameters

maxWarmupReplicas int

Returns

StreamsConfigBuilder

WithNumStandByReplicas(int)

Manages NUM_STANDBY_REPLICAS_CONFIG

public StreamsConfigBuilder WithNumStandByReplicas(int numStandByReplicas)

Parameters

numStandByReplicas int

Returns

StreamsConfigBuilder

WithNumStreamThreads(int)

Manages NUM_STREAM_THREADS_CONFIG

public StreamsConfigBuilder WithNumStreamThreads(int numStreamThreads)

Parameters

numStreamThreads int

Returns

StreamsConfigBuilder

WithPollMs(long)

Manages POLL_MS_CONFIG

public StreamsConfigBuilder WithPollMs(long pollMs)

Parameters

pollMs long

Returns

StreamsConfigBuilder

WithProbingRebalanceIntervalMs(long)

Manages PROBING_REBALANCE_INTERVAL_MS_CONFIG

public StreamsConfigBuilder WithProbingRebalanceIntervalMs(long probingRebalanceIntervalMs)

Parameters

probingRebalanceIntervalMs long

Returns

StreamsConfigBuilder

WithProcessingExceptionHandlerClass(Class)

Manages PROCESSING_EXCEPTION_HANDLER_CLASS_CONFIG

public StreamsConfigBuilder WithProcessingExceptionHandlerClass(Class processingExceptionHandlerClass)

Parameters

processingExceptionHandlerClass Class

Returns

StreamsConfigBuilder

WithProcessingGuarantee(string)

Manages PROCESSING_GUARANTEE_CONFIG: use AT_LEAST_ONCE or EXACTLY_ONCE_V2

public StreamsConfigBuilder WithProcessingGuarantee(string processingGuarantee)

Parameters

processingGuarantee string

Returns

StreamsConfigBuilder

WithProcessorWrapperClass(Class)

Manages PROCESSOR_WRAPPER_CLASS_CONFIG

public StreamsConfigBuilder WithProcessorWrapperClass(Class processorWrapperClass)

Parameters

processorWrapperClass Class

Returns

StreamsConfigBuilder

WithProductionExceptionHandlerClass(Class)

Manages PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIG

public StreamsConfigBuilder WithProductionExceptionHandlerClass(Class productionExceptionHandlerClass)

Parameters

productionExceptionHandlerClass Class

Returns

StreamsConfigBuilder

WithRackAwareAssignmentNonOverlapCost(int)

Manages RACK_AWARE_ASSIGNMENT_NON_OVERLAP_COST_CONFIG

public StreamsConfigBuilder WithRackAwareAssignmentNonOverlapCost(int rackAwareAssignmentNonOverlapCost)

Parameters

rackAwareAssignmentNonOverlapCost int

Returns

StreamsConfigBuilder

WithRackAwareAssignmentStrategy(string)

Manages RACK_AWARE_ASSIGNMENT_NON_OVERLAP_COST_CONFIG: use RACK_AWARE_ASSIGNMENT_STRATEGY_NONE or RACK_AWARE_ASSIGNMENT_STRATEGY_MIN_TRAFFIC

public StreamsConfigBuilder WithRackAwareAssignmentStrategy(string rackAwareAssignmentStrategy)

Parameters

rackAwareAssignmentStrategy string

Returns

StreamsConfigBuilder

WithRackAwareAssignmentTags(List<string>)

Manages RACK_AWARE_ASSIGNMENT_TAGS_CONFIG

public StreamsConfigBuilder WithRackAwareAssignmentTags(List<string> rackAwareAssignmentTags)

Parameters

rackAwareAssignmentTags List<string>

Returns

StreamsConfigBuilder

WithRackAwareAssignmentTrafficCost(int)

Manages RACK_AWARE_ASSIGNMENT_TRAFFIC_COST_CONFIG

public StreamsConfigBuilder WithRackAwareAssignmentTrafficCost(int rackAwareAssignmentTrafficCost)

Parameters

rackAwareAssignmentTrafficCost int

Returns

StreamsConfigBuilder

WithRepartitionPurgeIntervalMs(long)

Manages REPARTITION_PURGE_INTERVAL_MS_CONFIG

public StreamsConfigBuilder WithRepartitionPurgeIntervalMs(long repartitionPurgeIntervalMs)

Parameters

repartitionPurgeIntervalMs long

Returns

StreamsConfigBuilder

WithReplicationFactor(int)

Manages REPLICATION_FACTOR_CONFIG

public StreamsConfigBuilder WithReplicationFactor(int replicationFactor)

Parameters

replicationFactor int

Returns

StreamsConfigBuilder

WithRocksDbConfigSetterClass(Class)

Manages ROCKSDB_CONFIG_SETTER_CLASS_CONFIG

public StreamsConfigBuilder WithRocksDbConfigSetterClass(Class rocksDbConfigSetterClass)

Parameters

rocksDbConfigSetterClass Class

Returns

StreamsConfigBuilder

WithStateCleanupDelayMs(long)

Manages STATE_CLEANUP_DELAY_MS_CONFIG

public StreamsConfigBuilder WithStateCleanupDelayMs(long stateCleanupDelayMs)

Parameters

stateCleanupDelayMs long

Returns

StreamsConfigBuilder

WithStateDir(string)

Manages STATE_DIR_CONFIG

public StreamsConfigBuilder WithStateDir(string stateDir)

Parameters

stateDir string

Returns

StreamsConfigBuilder

WithStateStoreMaxBytesBuffering(long)

Manages STATESTORE_CACHE_MAX_BYTES_CONFIG

public StreamsConfigBuilder WithStateStoreMaxBytesBuffering(long stateStoreMaxBytesBuffering)

Parameters

stateStoreMaxBytesBuffering long

Returns

StreamsConfigBuilder

WithTaskAssignorClass(Class)

Manages TASK_ASSIGNOR_CLASS_CONFIG

public StreamsConfigBuilder WithTaskAssignorClass(Class taskAssignorClass)

Parameters

taskAssignorClass Class

Returns

StreamsConfigBuilder

WithTaskTimeoutMs(long)

Manages TASK_TIMEOUT_MS_CONFIG

public StreamsConfigBuilder WithTaskTimeoutMs(long taskTimeoutMs)

Parameters

taskTimeoutMs long

Returns

StreamsConfigBuilder

WithTopologyOptimization(bool)

Manages TOPOLOGY_OPTIMIZATION_CONFIG: use OPTIMIZE or NO_OPTIMIZATION

public StreamsConfigBuilder WithTopologyOptimization(bool topologyOptimization)

Parameters

topologyOptimization bool

Returns

StreamsConfigBuilder

WithUpgradeFrom(string)

Manages UPGRADE_FROM_CONFIG

public StreamsConfigBuilder WithUpgradeFrom(string upgradeFrom)

Parameters

upgradeFrom string

Returns

StreamsConfigBuilder

WithWindowStoreChangeLogAdditionalRetentionMs(long)

Manages WINDOW_STORE_CHANGE_LOG_ADDITIONAL_RETENTION_MS_CONFIG

public StreamsConfigBuilder WithWindowStoreChangeLogAdditionalRetentionMs(long windowStoreChangeLogAdditionalRetentionMs)

Parameters

windowStoreChangeLogAdditionalRetentionMs long

Returns

StreamsConfigBuilder
Edit this page