Table of Contents

Class TopicConfigBuilder

Namespace
MASES.KNet.Common
Assembly
MASES.KNet.dll

Builder for TopicConfig

public class TopicConfigBuilder : GenericConfigBuilder<TopicConfigBuilder>, INotifyPropertyChanged, IGenericSerDesFactory, IDisposable
Inheritance
TopicConfigBuilder
Implements
Inherited Members

Properties

CleanupPolicy

Manages CLEANUP_POLICY_CONFIG

public TopicConfigBuilder.CleanupPolicyTypes CleanupPolicy { get; set; }

Property Value

TopicConfigBuilder.CleanupPolicyTypes

CompressionType

Manages COMPRESSION_TYPE_CONFIG

public TopicConfigBuilder.CompressionTypes CompressionType { get; set; }

Property Value

TopicConfigBuilder.CompressionTypes

DeleteRetentionMs

Manages DELETE_RETENTION_MS_CONFIG

public int DeleteRetentionMs { get; set; }

Property Value

int

FileDeleteDelayMs

Manages FILE_DELETE_DELAY_MS_CONFIG

public int FileDeleteDelayMs { get; set; }

Property Value

int

FlushMessageInterval

Manages FLUSH_MESSAGES_INTERVAL_CONFIG

public int FlushMessageInterval { get; set; }

Property Value

int

FlushMs

Manages FLUSH_MS_CONFIG

public int FlushMs { get; set; }

Property Value

int

IndexIntervalBytes

Manages INDEX_INTERVAL_BYTES_CONFIG

public int IndexIntervalBytes { get; set; }

Property Value

int

LocalLogRetentionBytes

Manages LOCAL_LOG_RETENTION_BYTES_CONFIG

public int LocalLogRetentionBytes { get; set; }

Property Value

int

LocalLogRetentionMs

Manages LOCAL_LOG_RETENTION_MS_CONFIG

public int LocalLogRetentionMs { get; set; }

Property Value

int

MaxCompactationLagMs

Manages MAX_COMPACTION_LAG_MS_CONFIG

public int MaxCompactationLagMs { get; set; }

Property Value

int

MaxMessageBytes

Manages MAX_MESSAGE_BYTES_CONFIG

public int MaxMessageBytes { get; set; }

Property Value

int

MessageDownConversionEnable

Manages MESSAGE_DOWNCONVERSION_ENABLE_CONFIG

public bool MessageDownConversionEnable { get; set; }

Property Value

bool

MessageTimestampAfterMaxMs

Manages MESSAGE_TIMESTAMP_AFTER_MAX_MS_CONFIG

public int MessageTimestampAfterMaxMs { get; set; }

Property Value

int

MessageTimestampBeforeMaxMs

Manages MESSAGE_TIMESTAMP_BEFORE_MAX_MS_CONFIG

public int MessageTimestampBeforeMaxMs { get; set; }

Property Value

int

MessageTimestampType

Manages MESSAGE_TIMESTAMP_TYPE_CONFIG

public TopicConfigBuilder.MessageTimestampTypes MessageTimestampType { get; set; }

Property Value

TopicConfigBuilder.MessageTimestampTypes

MinCleanableDirtyRatio

Manages MIN_CLEANABLE_DIRTY_RATIO_CONFIG

public double MinCleanableDirtyRatio { get; set; }

Property Value

double

MinCompactationLagMs

Manages MIN_COMPACTION_LAG_MS_CONFIG

public int MinCompactationLagMs { get; set; }

Property Value

int

MinInSyncReplicas

Manages MIN_IN_SYNC_REPLICAS_CONFIG

public int MinInSyncReplicas { get; set; }

Property Value

int

Preallocate

Manages PREALLOCATE_CONFIG

public bool Preallocate { get; set; }

Property Value

bool

RemoteLogStorageEnable

Manages REMOTE_LOG_STORAGE_ENABLE_CONFIG

public bool RemoteLogStorageEnable { get; set; }

Property Value

bool

RetentionBytes

Manages RETENTION_BYTES_CONFIG

public int RetentionBytes { get; set; }

Property Value

int

RetentionMs

Manages RETENTION_MS_CONFIG

public int RetentionMs { get; set; }

Property Value

int

SegmentBytes

Manages SEGMENT_BYTES_CONFIG

public int SegmentBytes { get; set; }

Property Value

int

SegmentIndexBytes

Manages SEGMENT_INDEX_BYTES_CONFIG

public int SegmentIndexBytes { get; set; }

Property Value

int

SegmentJitterMs

Manages SEGMENT_JITTER_MS_CONFIG

public int SegmentJitterMs { get; set; }

Property Value

int

SegmentMs

Manages SEGMENT_MS_CONFIG

public int SegmentMs { get; set; }

Property Value

int

UncleanLeaderElectionEnable

Manages UNCLEAN_LEADER_ELECTION_ENABLE_CONFIG

public bool UncleanLeaderElectionEnable { get; set; }

Property Value

bool

Methods

WithCleanupPolicy(CleanupPolicyTypes)

Manages CLEANUP_POLICY_CONFIG

public TopicConfigBuilder WithCleanupPolicy(TopicConfigBuilder.CleanupPolicyTypes cleanupPolicy)

Parameters

cleanupPolicy TopicConfigBuilder.CleanupPolicyTypes

Returns

TopicConfigBuilder

WithCompressionType(CompressionTypes)

Manages COMPRESSION_TYPE_CONFIG

public TopicConfigBuilder WithCompressionType(TopicConfigBuilder.CompressionTypes compressionType)

Parameters

compressionType TopicConfigBuilder.CompressionTypes

Returns

TopicConfigBuilder

WithDeleteRetentionMs(int)

Manages DELETE_RETENTION_MS_CONFIG

public TopicConfigBuilder WithDeleteRetentionMs(int deleteRetentionMs)

Parameters

deleteRetentionMs int

Returns

TopicConfigBuilder

WithFileDeleteDelayMs(int)

Manages FILE_DELETE_DELAY_MS_CONFIG

public TopicConfigBuilder WithFileDeleteDelayMs(int fileDeleteDelayMs)

Parameters

fileDeleteDelayMs int

Returns

TopicConfigBuilder

WithFlushMessageInterval(int)

Manages FLUSH_MESSAGES_INTERVAL_CONFIG

public TopicConfigBuilder WithFlushMessageInterval(int flushMessageInterval)

Parameters

flushMessageInterval int

Returns

TopicConfigBuilder

WithFlushMs(int)

Manages FLUSH_MS_CONFIG

public TopicConfigBuilder WithFlushMs(int flushMs)

Parameters

flushMs int

Returns

TopicConfigBuilder

WithIndexIntervalBytes(int)

Manages INDEX_INTERVAL_BYTES_CONFIG

public TopicConfigBuilder WithIndexIntervalBytes(int indexIntervalBytes)

Parameters

indexIntervalBytes int

Returns

TopicConfigBuilder

WithLocalLogRetentionBytes(int)

Manages LOCAL_LOG_RETENTION_BYTES_CONFIG

public TopicConfigBuilder WithLocalLogRetentionBytes(int localLogRetentionBytes)

Parameters

localLogRetentionBytes int

Returns

TopicConfigBuilder

WithLocalLogRetentionMs(int)

Manages LOCAL_LOG_RETENTION_MS_CONFIG

public TopicConfigBuilder WithLocalLogRetentionMs(int localLogRetentionMs)

Parameters

localLogRetentionMs int

Returns

TopicConfigBuilder

WithMaxCompactationLagMs(int)

Manages MAX_COMPACTION_LAG_MS_CONFIG

public TopicConfigBuilder WithMaxCompactationLagMs(int maxCompactationLagMs)

Parameters

maxCompactationLagMs int

Returns

TopicConfigBuilder

WithMaxMessageBytes(int)

Manages MAX_MESSAGE_BYTES_CONFIG

public TopicConfigBuilder WithMaxMessageBytes(int maxMessageBytes)

Parameters

maxMessageBytes int

Returns

TopicConfigBuilder

WithMessageDownConversionEnable(bool)

Manages MESSAGE_DOWNCONVERSION_ENABLE_CONFIG

public TopicConfigBuilder WithMessageDownConversionEnable(bool messageDownConversionEnable)

Parameters

messageDownConversionEnable bool

Returns

TopicConfigBuilder

WithMessageTimestampAfterMaxMs(int)

Manages MESSAGE_TIMESTAMP_AFTER_MAX_MS_CONFIG

public TopicConfigBuilder WithMessageTimestampAfterMaxMs(int messageTimestampAfterMaxMs)

Parameters

messageTimestampAfterMaxMs int

Returns

TopicConfigBuilder

WithMessageTimestampBeforeMaxMs(int)

Manages MESSAGE_TIMESTAMP_BEFORE_MAX_MS_CONFIG

public TopicConfigBuilder WithMessageTimestampBeforeMaxMs(int messageTimestampBeforeMaxMs)

Parameters

messageTimestampBeforeMaxMs int

Returns

TopicConfigBuilder

WithMessageTimestampType(MessageTimestampTypes)

Manages MESSAGE_TIMESTAMP_TYPE_CONFIG

public TopicConfigBuilder WithMessageTimestampType(TopicConfigBuilder.MessageTimestampTypes messageTimestampType)

Parameters

messageTimestampType TopicConfigBuilder.MessageTimestampTypes

Returns

TopicConfigBuilder

WithMinCleanableDirtyRatio(double)

Manages MIN_CLEANABLE_DIRTY_RATIO_CONFIG

public TopicConfigBuilder WithMinCleanableDirtyRatio(double minCleanableDirtyRatio)

Parameters

minCleanableDirtyRatio double

Returns

TopicConfigBuilder

WithMinCompactationLagMs(int)

Manages MIN_COMPACTION_LAG_MS_CONFIG

public TopicConfigBuilder WithMinCompactationLagMs(int minCompactationLagMs)

Parameters

minCompactationLagMs int

Returns

TopicConfigBuilder

WithMinInSyncReplicas(int)

Manages MIN_IN_SYNC_REPLICAS_CONFIG

public TopicConfigBuilder WithMinInSyncReplicas(int minInSyncReplicas)

Parameters

minInSyncReplicas int

Returns

TopicConfigBuilder

WithPreallocate(bool)

Manages PREALLOCATE_CONFIG

public TopicConfigBuilder WithPreallocate(bool preallocate)

Parameters

preallocate bool

Returns

TopicConfigBuilder

WithRemoteLogStorageEnable(bool)

Manages REMOTE_LOG_STORAGE_ENABLE_CONFIG

public TopicConfigBuilder WithRemoteLogStorageEnable(bool remoteLogStorageEnable)

Parameters

remoteLogStorageEnable bool

Returns

TopicConfigBuilder

WithRetentionBytes(int)

Manages RETENTION_BYTES_CONFIG

public TopicConfigBuilder WithRetentionBytes(int retentionBytes)

Parameters

retentionBytes int

Returns

TopicConfigBuilder

WithRetentionMs(int)

Manages RETENTION_MS_CONFIG

public TopicConfigBuilder WithRetentionMs(int retentionMs)

Parameters

retentionMs int

Returns

TopicConfigBuilder

WithSegmentBytes(int)

Manages SEGMENT_BYTES_CONFIG

public TopicConfigBuilder WithSegmentBytes(int segmentBytes)

Parameters

segmentBytes int

Returns

TopicConfigBuilder

WithSegmentIndexBytes(int)

Manages SEGMENT_INDEX_BYTES_CONFIG

public TopicConfigBuilder WithSegmentIndexBytes(int segmentIndexBytes)

Parameters

segmentIndexBytes int

Returns

TopicConfigBuilder

WithSegmentJitterMs(int)

Manages SEGMENT_JITTER_MS_CONFIG

public TopicConfigBuilder WithSegmentJitterMs(int segmentJitterMs)

Parameters

segmentJitterMs int

Returns

TopicConfigBuilder

WithSegmentMs(int)

Manages SEGMENT_MS_CONFIG

public TopicConfigBuilder WithSegmentMs(int segmentMs)

Parameters

segmentMs int

Returns

TopicConfigBuilder

WithUncleanLeaderElectionEnable(bool)

Manages UNCLEAN_LEADER_ELECTION_ENABLE_CONFIG

public TopicConfigBuilder WithUncleanLeaderElectionEnable(bool uncleanLeaderElectionEnable)

Parameters

uncleanLeaderElectionEnable bool

Returns

TopicConfigBuilder
Edit this page