Table of Contents

Class StreamsConfigBuilder

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

Builder for StreamsConfig

public class StreamsConfigBuilder : CommonClientConfigsBuilder<StreamsConfigBuilder>, INotifyPropertyChanged, IGenericSerDesFactory, IDisposable
Inheritance
StreamsConfigBuilder
Implements
Inherited Members

Properties

AcceptableRecoveryLag

Manages ACCEPTABLE_RECOVERY_LAG_CONFIG

public long AcceptableRecoveryLag { get; set; }

Property Value

long

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

DefaultDeserializationExceptionHandlerClass

Manages DEFAULT_DESERIALIZATION_EXCEPTION_HANDLER_CLASS_CONFIG

public Class DefaultDeserializationExceptionHandlerClass { get; set; }

Property Value

Class

DefaultKeySerdeClass

Manages DEFAULT_KEY_SERDE_CLASS_CONFIG

public Class DefaultKeySerdeClass { get; set; }

Property Value

Class

DefaultProductionExceptionHandlerClass

Manages DEFAULT_PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIG

public Class DefaultProductionExceptionHandlerClass { 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

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

ProcessingGuarantee

Manages PROCESSING_GUARANTEE_CONFIG: use AT_LEAST_ONCE or EXACTLY_ONCE_V2

public string ProcessingGuarantee { get; set; }

Property Value

string

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

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

WindowSizeMs

Manages WINDOW_SIZE_MS_CONFIG

public long WindowSizeMs { get; set; }

Property Value

long

WindowStoreChangeLogAdditionalRetentionMs

Manages WINDOW_STORE_CHANGE_LOG_ADDITIONAL_RETENTION_MS_CONFIG

public long WindowStoreChangeLogAdditionalRetentionMs { get; set; }

Property Value

long

WindowedInnerClassSerde

Manages WINDOWED_INNER_CLASS_SERDE

public string WindowedInnerClassSerde { get; set; }

Property Value

string

Methods

WithAcceptableRecoveryLag(long)

Manages ACCEPTABLE_RECOVERY_LAG_CONFIG

public StreamsConfigBuilder WithAcceptableRecoveryLag(long acceptableRecoveryLag)

Parameters

acceptableRecoveryLag long

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

WithDefaultDeserializationExceptionHandlerClass(Class)

Manages DEFAULT_DESERIALIZATION_EXCEPTION_HANDLER_CLASS_CONFIG

public StreamsConfigBuilder WithDefaultDeserializationExceptionHandlerClass(Class defaultDeserializationExceptionHandlerClass)

Parameters

defaultDeserializationExceptionHandlerClass Class

Returns

StreamsConfigBuilder

WithDefaultKeySerdeClass(Class)

Manages DEFAULT_KEY_SERDE_CLASS_CONFIG

public StreamsConfigBuilder WithDefaultKeySerdeClass(Class defaultKeySerdeClass)

Parameters

defaultKeySerdeClass Class

Returns

StreamsConfigBuilder

WithDefaultProductionExceptionHandlerClass(Class)

Manages DEFAULT_PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIG

public StreamsConfigBuilder WithDefaultProductionExceptionHandlerClass(Class defaultProductionExceptionHandlerClass)

Parameters

defaultProductionExceptionHandlerClass 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

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

WithProcessingGuarantee(string)

Manages PROCESSING_GUARANTEE_CONFIG: use AT_LEAST_ONCE or EXACTLY_ONCE_V2

public StreamsConfigBuilder WithProcessingGuarantee(string processingGuarantee)

Parameters

processingGuarantee string

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

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

WithWindowSizeMs(long)

Manages WINDOW_SIZE_MS_CONFIG

public StreamsConfigBuilder WithWindowSizeMs(long windowSizeMs)

Parameters

windowSizeMs long

Returns

StreamsConfigBuilder

WithWindowStoreChangeLogAdditionalRetentionMs(long)

Manages WINDOW_STORE_CHANGE_LOG_ADDITIONAL_RETENTION_MS_CONFIG

public StreamsConfigBuilder WithWindowStoreChangeLogAdditionalRetentionMs(long windowStoreChangeLogAdditionalRetentionMs)

Parameters

windowStoreChangeLogAdditionalRetentionMs long

Returns

StreamsConfigBuilder

WithWindowedInnerClassSerde(string)

Manages WINDOWED_INNER_CLASS_SERDE

public StreamsConfigBuilder WithWindowedInnerClassSerde(string windowedInnerClassSerde)

Parameters

windowedInnerClassSerde string

Returns

StreamsConfigBuilder
Edit this page