Class TopicConfigBuilder
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
CompressionType
Manages COMPRESSION_TYPE_CONFIG
public TopicConfigBuilder.CompressionTypes CompressionType { get; set; }
Property Value
DeleteRetentionMs
Manages DELETE_RETENTION_MS_CONFIG
public int DeleteRetentionMs { get; set; }
Property Value
FileDeleteDelayMs
Manages FILE_DELETE_DELAY_MS_CONFIG
public int FileDeleteDelayMs { get; set; }
Property Value
FlushMessageInterval
Manages FLUSH_MESSAGES_INTERVAL_CONFIG
public int FlushMessageInterval { get; set; }
Property Value
FlushMs
Manages FLUSH_MS_CONFIG
public int FlushMs { get; set; }
Property Value
IndexIntervalBytes
Manages INDEX_INTERVAL_BYTES_CONFIG
public int IndexIntervalBytes { get; set; }
Property Value
LocalLogRetentionBytes
Manages LOCAL_LOG_RETENTION_BYTES_CONFIG
public int LocalLogRetentionBytes { get; set; }
Property Value
LocalLogRetentionMs
Manages LOCAL_LOG_RETENTION_MS_CONFIG
public int LocalLogRetentionMs { get; set; }
Property Value
MaxCompactationLagMs
Manages MAX_COMPACTION_LAG_MS_CONFIG
public int MaxCompactationLagMs { get; set; }
Property Value
MaxMessageBytes
Manages MAX_MESSAGE_BYTES_CONFIG
public int MaxMessageBytes { get; set; }
Property Value
MessageTimestampAfterMaxMs
public int MessageTimestampAfterMaxMs { get; set; }
Property Value
MessageTimestampBeforeMaxMs
public int MessageTimestampBeforeMaxMs { get; set; }
Property Value
MessageTimestampType
Manages MESSAGE_TIMESTAMP_TYPE_CONFIG
public TopicConfigBuilder.MessageTimestampTypes MessageTimestampType { get; set; }
Property Value
MinCleanableDirtyRatio
Manages MIN_CLEANABLE_DIRTY_RATIO_CONFIG
public double MinCleanableDirtyRatio { get; set; }
Property Value
MinCompactationLagMs
Manages MIN_COMPACTION_LAG_MS_CONFIG
public int MinCompactationLagMs { get; set; }
Property Value
MinInSyncReplicas
Manages MIN_IN_SYNC_REPLICAS_CONFIG
public int MinInSyncReplicas { get; set; }
Property Value
Preallocate
Manages PREALLOCATE_CONFIG
public bool Preallocate { get; set; }
Property Value
RemoteLogStorageEnable
Manages REMOTE_LOG_STORAGE_ENABLE_CONFIG
public bool RemoteLogStorageEnable { get; set; }
Property Value
RetentionBytes
Manages RETENTION_BYTES_CONFIG
public int RetentionBytes { get; set; }
Property Value
RetentionMs
Manages RETENTION_MS_CONFIG
public int RetentionMs { get; set; }
Property Value
SegmentBytes
Manages SEGMENT_BYTES_CONFIG
public int SegmentBytes { get; set; }
Property Value
SegmentIndexBytes
Manages SEGMENT_INDEX_BYTES_CONFIG
public int SegmentIndexBytes { get; set; }
Property Value
SegmentJitterMs
Manages SEGMENT_JITTER_MS_CONFIG
public int SegmentJitterMs { get; set; }
Property Value
SegmentMs
Manages SEGMENT_MS_CONFIG
public int SegmentMs { get; set; }
Property Value
UncleanLeaderElectionEnable
public bool UncleanLeaderElectionEnable { get; set; }
Property Value
Methods
WithCleanupPolicy(CleanupPolicyTypes)
Manages CLEANUP_POLICY_CONFIG
public TopicConfigBuilder WithCleanupPolicy(TopicConfigBuilder.CleanupPolicyTypes cleanupPolicy)
Parameters
cleanupPolicy
TopicConfigBuilder.CleanupPolicyTypes
Returns
WithCompressionType(CompressionTypes)
Manages COMPRESSION_TYPE_CONFIG
public TopicConfigBuilder WithCompressionType(TopicConfigBuilder.CompressionTypes compressionType)
Parameters
compressionType
TopicConfigBuilder.CompressionTypes
Returns
WithDeleteRetentionMs(int)
Manages DELETE_RETENTION_MS_CONFIG
public TopicConfigBuilder WithDeleteRetentionMs(int deleteRetentionMs)
Parameters
deleteRetentionMs
int
Returns
WithFileDeleteDelayMs(int)
Manages FILE_DELETE_DELAY_MS_CONFIG
public TopicConfigBuilder WithFileDeleteDelayMs(int fileDeleteDelayMs)
Parameters
fileDeleteDelayMs
int
Returns
WithFlushMessageInterval(int)
Manages FLUSH_MESSAGES_INTERVAL_CONFIG
public TopicConfigBuilder WithFlushMessageInterval(int flushMessageInterval)
Parameters
flushMessageInterval
int
Returns
WithFlushMs(int)
Manages FLUSH_MS_CONFIG
public TopicConfigBuilder WithFlushMs(int flushMs)
Parameters
flushMs
int
Returns
WithIndexIntervalBytes(int)
Manages INDEX_INTERVAL_BYTES_CONFIG
public TopicConfigBuilder WithIndexIntervalBytes(int indexIntervalBytes)
Parameters
indexIntervalBytes
int
Returns
WithLocalLogRetentionBytes(int)
Manages LOCAL_LOG_RETENTION_BYTES_CONFIG
public TopicConfigBuilder WithLocalLogRetentionBytes(int localLogRetentionBytes)
Parameters
localLogRetentionBytes
int
Returns
WithLocalLogRetentionMs(int)
Manages LOCAL_LOG_RETENTION_MS_CONFIG
public TopicConfigBuilder WithLocalLogRetentionMs(int localLogRetentionMs)
Parameters
localLogRetentionMs
int
Returns
WithMaxCompactationLagMs(int)
Manages MAX_COMPACTION_LAG_MS_CONFIG
public TopicConfigBuilder WithMaxCompactationLagMs(int maxCompactationLagMs)
Parameters
maxCompactationLagMs
int
Returns
WithMaxMessageBytes(int)
Manages MAX_MESSAGE_BYTES_CONFIG
public TopicConfigBuilder WithMaxMessageBytes(int maxMessageBytes)
Parameters
maxMessageBytes
int
Returns
WithMessageTimestampAfterMaxMs(int)
public TopicConfigBuilder WithMessageTimestampAfterMaxMs(int messageTimestampAfterMaxMs)
Parameters
messageTimestampAfterMaxMs
int
Returns
WithMessageTimestampBeforeMaxMs(int)
public TopicConfigBuilder WithMessageTimestampBeforeMaxMs(int messageTimestampBeforeMaxMs)
Parameters
messageTimestampBeforeMaxMs
int
Returns
WithMessageTimestampType(MessageTimestampTypes)
Manages MESSAGE_TIMESTAMP_TYPE_CONFIG
public TopicConfigBuilder WithMessageTimestampType(TopicConfigBuilder.MessageTimestampTypes messageTimestampType)
Parameters
messageTimestampType
TopicConfigBuilder.MessageTimestampTypes
Returns
WithMinCleanableDirtyRatio(double)
Manages MIN_CLEANABLE_DIRTY_RATIO_CONFIG
public TopicConfigBuilder WithMinCleanableDirtyRatio(double minCleanableDirtyRatio)
Parameters
minCleanableDirtyRatio
double
Returns
WithMinCompactationLagMs(int)
Manages MIN_COMPACTION_LAG_MS_CONFIG
public TopicConfigBuilder WithMinCompactationLagMs(int minCompactationLagMs)
Parameters
minCompactationLagMs
int
Returns
WithMinInSyncReplicas(int)
Manages MIN_IN_SYNC_REPLICAS_CONFIG
public TopicConfigBuilder WithMinInSyncReplicas(int minInSyncReplicas)
Parameters
minInSyncReplicas
int
Returns
WithPreallocate(bool)
Manages PREALLOCATE_CONFIG
public TopicConfigBuilder WithPreallocate(bool preallocate)
Parameters
preallocate
bool
Returns
WithRemoteLogStorageEnable(bool)
Manages REMOTE_LOG_STORAGE_ENABLE_CONFIG
public TopicConfigBuilder WithRemoteLogStorageEnable(bool remoteLogStorageEnable)
Parameters
remoteLogStorageEnable
bool
Returns
WithRetentionBytes(int)
Manages RETENTION_BYTES_CONFIG
public TopicConfigBuilder WithRetentionBytes(int retentionBytes)
Parameters
retentionBytes
int
Returns
WithRetentionMs(int)
Manages RETENTION_MS_CONFIG
public TopicConfigBuilder WithRetentionMs(int retentionMs)
Parameters
retentionMs
int
Returns
WithSegmentBytes(int)
Manages SEGMENT_BYTES_CONFIG
public TopicConfigBuilder WithSegmentBytes(int segmentBytes)
Parameters
segmentBytes
int
Returns
WithSegmentIndexBytes(int)
Manages SEGMENT_INDEX_BYTES_CONFIG
public TopicConfigBuilder WithSegmentIndexBytes(int segmentIndexBytes)
Parameters
segmentIndexBytes
int
Returns
WithSegmentJitterMs(int)
Manages SEGMENT_JITTER_MS_CONFIG
public TopicConfigBuilder WithSegmentJitterMs(int segmentJitterMs)
Parameters
segmentJitterMs
int
Returns
WithSegmentMs(int)
Manages SEGMENT_MS_CONFIG
public TopicConfigBuilder WithSegmentMs(int segmentMs)
Parameters
segmentMs
int
Returns
WithUncleanLeaderElectionEnable(bool)
public TopicConfigBuilder WithUncleanLeaderElectionEnable(bool uncleanLeaderElectionEnable)
Parameters
uncleanLeaderElectionEnable
bool