Table of Contents

Class TopicConfigBuilder

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

Builder for TopicConfig

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

Properties

CleanupPolicy

Manages CLEANUP_POLICY_CONFIG

public TopicConfigBuilder.CleanupPolicyTypes CleanupPolicy { get; set; }

Property Value

TopicConfigBuilder.CleanupPolicyTypes

CompressionGzipLevel

Manages COMPRESSION_GZIP_LEVEL_CONFIG

public int CompressionGzipLevel { get; set; }

Property Value

int

CompressionLz4Level

Manages COMPRESSION_LZ4_LEVEL_CONFIG

public int CompressionLz4Level { get; set; }

Property Value

int

CompressionType

Manages COMPRESSION_TYPE_CONFIG

public TopicConfigBuilder.CompressionTypes CompressionType { get; set; }

Property Value

TopicConfigBuilder.CompressionTypes

CompressionZstdLevel

Manages COMPRESSION_ZSTD_LEVEL_CONFIG

public int CompressionZstdLevel { get; set; }

Property Value

int

DeleteRetentionMs

Manages DELETE_RETENTION_MS_CONFIG

public long DeleteRetentionMs { get; set; }

Property Value

long

FileDeleteDelayMs

Manages FILE_DELETE_DELAY_MS_CONFIG

public long FileDeleteDelayMs { get; set; }

Property Value

long

FlushMessageInterval

Manages FLUSH_MESSAGES_INTERVAL_CONFIG

public long FlushMessageInterval { get; set; }

Property Value

long

FlushMs

Manages FLUSH_MS_CONFIG

public long FlushMs { get; set; }

Property Value

long

IndexIntervalBytes

Manages INDEX_INTERVAL_BYTES_CONFIG

public int IndexIntervalBytes { get; set; }

Property Value

int

LocalLogRetentionBytes

Manages LOCAL_LOG_RETENTION_BYTES_CONFIG

public long LocalLogRetentionBytes { get; set; }

Property Value

long

LocalLogRetentionMs

Manages LOCAL_LOG_RETENTION_MS_CONFIG

public long LocalLogRetentionMs { get; set; }

Property Value

long

MaxCompactationLagMs

Manages MAX_COMPACTION_LAG_MS_CONFIG

public long MaxCompactationLagMs { get; set; }

Property Value

long

MaxMessageBytes

Manages MAX_MESSAGE_BYTES_CONFIG

public int MaxMessageBytes { get; set; }

Property Value

int

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 long MinCompactationLagMs { get; set; }

Property Value

long

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

RemoteLogCopyDisable

Manages REMOTE_LOG_COPY_DISABLE_CONFIG

public bool RemoteLogCopyDisable { get; set; }

Property Value

bool

RemoteLogDeleteOnDisable

Manages REMOTE_LOG_DELETE_ON_DISABLE_CONFIG

public bool RemoteLogDeleteOnDisable { 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 long RetentionBytes { get; set; }

Property Value

long

RetentionMs

Manages RETENTION_MS_CONFIG

public long RetentionMs { get; set; }

Property Value

long

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 long SegmentJitterMs { get; set; }

Property Value

long

SegmentMs

Manages SEGMENT_MS_CONFIG

public long SegmentMs { get; set; }

Property Value

long

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

WithCompressionGzipLevel(int)

Manages COMPRESSION_GZIP_LEVEL_CONFIG

public TopicConfigBuilder WithCompressionGzipLevel(int compressionGzipLevel)

Parameters

compressionGzipLevel int

Returns

TopicConfigBuilder

WithCompressionLz4Level(int)

Manages COMPRESSION_LZ4_LEVEL_CONFIG

public TopicConfigBuilder WithCompressionLz4Level(int compressionLz4Level)

Parameters

compressionLz4Level int

Returns

TopicConfigBuilder

WithCompressionType(CompressionTypes)

Manages COMPRESSION_TYPE_CONFIG

public TopicConfigBuilder WithCompressionType(TopicConfigBuilder.CompressionTypes compressionType)

Parameters

compressionType TopicConfigBuilder.CompressionTypes

Returns

TopicConfigBuilder

WithCompressionZstdLevel(int)

Manages COMPRESSION_ZSTD_LEVEL_CONFIG

public TopicConfigBuilder WithCompressionZstdLevel(int compressionZstdLevel)

Parameters

compressionZstdLevel int

Returns

TopicConfigBuilder

WithDeleteRetentionMs(long)

Manages DELETE_RETENTION_MS_CONFIG

public TopicConfigBuilder WithDeleteRetentionMs(long deleteRetentionMs)

Parameters

deleteRetentionMs long

Returns

TopicConfigBuilder

WithFileDeleteDelayMs(long)

Manages FILE_DELETE_DELAY_MS_CONFIG

public TopicConfigBuilder WithFileDeleteDelayMs(long fileDeleteDelayMs)

Parameters

fileDeleteDelayMs long

Returns

TopicConfigBuilder

WithFlushMessageInterval(long)

Manages FLUSH_MESSAGES_INTERVAL_CONFIG

public TopicConfigBuilder WithFlushMessageInterval(long flushMessageInterval)

Parameters

flushMessageInterval long

Returns

TopicConfigBuilder

WithFlushMs(long)

Manages FLUSH_MS_CONFIG

public TopicConfigBuilder WithFlushMs(long flushMs)

Parameters

flushMs long

Returns

TopicConfigBuilder

WithIndexIntervalBytes(int)

Manages INDEX_INTERVAL_BYTES_CONFIG

public TopicConfigBuilder WithIndexIntervalBytes(int indexIntervalBytes)

Parameters

indexIntervalBytes int

Returns

TopicConfigBuilder

WithLocalLogRetentionBytes(long)

Manages LOCAL_LOG_RETENTION_BYTES_CONFIG

public TopicConfigBuilder WithLocalLogRetentionBytes(long localLogRetentionBytes)

Parameters

localLogRetentionBytes long

Returns

TopicConfigBuilder

WithLocalLogRetentionMs(long)

Manages LOCAL_LOG_RETENTION_MS_CONFIG

public TopicConfigBuilder WithLocalLogRetentionMs(long localLogRetentionMs)

Parameters

localLogRetentionMs long

Returns

TopicConfigBuilder

WithMaxCompactationLagMs(long)

Manages MAX_COMPACTION_LAG_MS_CONFIG

public TopicConfigBuilder WithMaxCompactationLagMs(long maxCompactationLagMs)

Parameters

maxCompactationLagMs long

Returns

TopicConfigBuilder

WithMaxMessageBytes(int)

Manages MAX_MESSAGE_BYTES_CONFIG

public TopicConfigBuilder WithMaxMessageBytes(int maxMessageBytes)

Parameters

maxMessageBytes int

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(long)

Manages MIN_COMPACTION_LAG_MS_CONFIG

public TopicConfigBuilder WithMinCompactationLagMs(long minCompactationLagMs)

Parameters

minCompactationLagMs long

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

WithRemoteLogCopyDisable(bool)

Manages REMOTE_LOG_COPY_DISABLE_CONFIG

public TopicConfigBuilder WithRemoteLogCopyDisable(bool remoteLogCopyDisable)

Parameters

remoteLogCopyDisable bool

Returns

TopicConfigBuilder

WithRemoteLogDeleteOnDisable(bool)

Manages REMOTE_LOG_DELETE_ON_DISABLE_CONFIG

public TopicConfigBuilder WithRemoteLogDeleteOnDisable(bool remoteLogDeleteOnDisable)

Parameters

remoteLogDeleteOnDisable bool

Returns

TopicConfigBuilder

WithRemoteLogStorageEnable(bool)

Manages REMOTE_LOG_STORAGE_ENABLE_CONFIG

public TopicConfigBuilder WithRemoteLogStorageEnable(bool remoteLogStorageEnable)

Parameters

remoteLogStorageEnable bool

Returns

TopicConfigBuilder

WithRetentionBytes(long)

Manages RETENTION_BYTES_CONFIG

public TopicConfigBuilder WithRetentionBytes(long retentionBytes)

Parameters

retentionBytes long

Returns

TopicConfigBuilder

WithRetentionMs(long)

Manages RETENTION_MS_CONFIG

public TopicConfigBuilder WithRetentionMs(long retentionMs)

Parameters

retentionMs long

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(long)

Manages SEGMENT_JITTER_MS_CONFIG

public TopicConfigBuilder WithSegmentJitterMs(long segmentJitterMs)

Parameters

segmentJitterMs long

Returns

TopicConfigBuilder

WithSegmentMs(long)

Manages SEGMENT_MS_CONFIG

public TopicConfigBuilder WithSegmentMs(long segmentMs)

Parameters

segmentMs long

Returns

TopicConfigBuilder

WithUncleanLeaderElectionEnable(bool)

Manages UNCLEAN_LEADER_ELECTION_ENABLE_CONFIG

public TopicConfigBuilder WithUncleanLeaderElectionEnable(bool uncleanLeaderElectionEnable)

Parameters

uncleanLeaderElectionEnable bool

Returns

TopicConfigBuilder
Edit this page