DatabaseKafkaTopicConfigArgs

data class DatabaseKafkaTopicConfigArgs(val cleanupPolicy: Output<String>? = null, val compressionType: Output<String>? = null, val deleteRetentionMs: Output<String>? = null, val fileDeleteDelayMs: Output<String>? = null, val flushMessages: Output<String>? = null, val flushMs: Output<String>? = null, val indexIntervalBytes: Output<String>? = null, val maxCompactionLagMs: Output<String>? = null, val maxMessageBytes: Output<String>? = null, val messageDownConversionEnable: Output<Boolean>? = null, val messageFormatVersion: Output<String>? = null, val messageTimestampDifferenceMaxMs: Output<String>? = null, val messageTimestampType: Output<String>? = null, val minCleanableDirtyRatio: Output<Double>? = null, val minCompactionLagMs: Output<String>? = null, val minInsyncReplicas: Output<Int>? = null, val preallocate: Output<Boolean>? = null, val retentionBytes: Output<String>? = null, val retentionMs: Output<String>? = null, val segmentBytes: Output<String>? = null, val segmentIndexBytes: Output<String>? = null, val segmentJitterMs: Output<String>? = null, val segmentMs: Output<String>? = null) : ConvertibleToJava<DatabaseKafkaTopicConfigArgs>

Constructors

Link copied to clipboard
constructor(cleanupPolicy: Output<String>? = null, compressionType: Output<String>? = null, deleteRetentionMs: Output<String>? = null, fileDeleteDelayMs: Output<String>? = null, flushMessages: Output<String>? = null, flushMs: Output<String>? = null, indexIntervalBytes: Output<String>? = null, maxCompactionLagMs: Output<String>? = null, maxMessageBytes: Output<String>? = null, messageDownConversionEnable: Output<Boolean>? = null, messageFormatVersion: Output<String>? = null, messageTimestampDifferenceMaxMs: Output<String>? = null, messageTimestampType: Output<String>? = null, minCleanableDirtyRatio: Output<Double>? = null, minCompactionLagMs: Output<String>? = null, minInsyncReplicas: Output<Int>? = null, preallocate: Output<Boolean>? = null, retentionBytes: Output<String>? = null, retentionMs: Output<String>? = null, segmentBytes: Output<String>? = null, segmentIndexBytes: Output<String>? = null, segmentJitterMs: Output<String>? = null, segmentMs: Output<String>? = null)

Properties

Link copied to clipboard
val cleanupPolicy: Output<String>? = null

The topic cleanup policy that describes whether messages should be deleted, compacted, or both when retention policies are violated. This may be one of "delete", "compact", or "compact_delete".

Link copied to clipboard
val compressionType: Output<String>? = null

The topic compression codecs used for a given topic. This may be one of "uncompressed", "gzip", "snappy", "lz4", "producer", "zstd". "uncompressed" indicates that there is no compression and "producer" retains the original compression codec set by the producer.

Link copied to clipboard
val deleteRetentionMs: Output<String>? = null

The amount of time, in ms, that deleted records are retained.

Link copied to clipboard
val fileDeleteDelayMs: Output<String>? = null

The amount of time, in ms, to wait before deleting a topic log segment from the filesystem.

Link copied to clipboard
val flushMessages: Output<String>? = null

The number of messages accumulated on a topic partition before they are flushed to disk.

Link copied to clipboard
val flushMs: Output<String>? = null

The maximum time, in ms, that a topic is kept in memory before being flushed to disk.

Link copied to clipboard
val indexIntervalBytes: Output<String>? = null

The interval, in bytes, in which entries are added to the offset index.

Link copied to clipboard
val maxCompactionLagMs: Output<String>? = null

The maximum time, in ms, that a particular message will remain uncompacted. This will not apply if the compression_type is set to "uncompressed" or it is set to producer and the producer is not using compression.

Link copied to clipboard
val maxMessageBytes: Output<String>? = null

The maximum size, in bytes, of a message.

Link copied to clipboard

Determines whether down-conversion of message formats for consumers is enabled.

Link copied to clipboard
val messageFormatVersion: Output<String>? = null

The version of the inter-broker protocol that will be used. This may be one of "0.8.0", "0.8.1", "0.8.2", "0.9.0", "0.10.0", "0.10.0-IV0", "0.10.0-IV1", "0.10.1", "0.10.1-IV0", "0.10.1-IV1", "0.10.1-IV2", "0.10.2", "0.10.2-IV0", "0.11.0", "0.11.0-IV0", "0.11.0-IV1", "0.11.0-IV2", "1.0", "1.0-IV0", "1.1", "1.1-IV0", "2.0", "2.0-IV0", "2.0-IV1", "2.1", "2.1-IV0", "2.1-IV1", "2.1-IV2", "2.2", "2.2-IV0", "2.2-IV1", "2.3", "2.3-IV0", "2.3-IV1", "2.4", "2.4-IV0", "2.4-IV1", "2.5", "2.5-IV0", "2.6", "2.6-IV0", "2.7", "2.7-IV0", "2.7-IV1", "2.7-IV2", "2.8", "2.8-IV0", "2.8-IV1", "3.0", "3.0-IV0", "3.0-IV1", "3.1", "3.1-IV0", "3.2", "3.2-IV0", "3.3", "3.3-IV0", "3.3-IV1", "3.3-IV2", "3.3-IV3", "3.4", "3.4-IV0", "3.5", "3.5-IV0", "3.5-IV1", "3.5-IV2", "3.6", "3.6-IV0", "3.6-IV1", "3.6-IV2".

Link copied to clipboard

The maximum difference, in ms, between the timestamp specific in a message and when the broker receives the message.

Link copied to clipboard
val messageTimestampType: Output<String>? = null

Specifies which timestamp to use for the message. This may be one of "create_time" or "log_append_time".

Link copied to clipboard
val minCleanableDirtyRatio: Output<Double>? = null

A scale between 0.0 and 1.0 which controls the frequency of the compactor. Larger values mean more frequent compactions. This is often paired with max_compaction_lag_ms to control the compactor frequency.

Link copied to clipboard
val minCompactionLagMs: Output<String>? = null
Link copied to clipboard
val minInsyncReplicas: Output<Int>? = null

The number of replicas that must acknowledge a write before it is considered successful. -1 is a special setting to indicate that all nodes must ack a message before a write is considered successful. Default is 1, indicating at least 1 replica must acknowledge a write to be considered successful.

Link copied to clipboard
val preallocate: Output<Boolean>? = null

Determines whether to preallocate a file on disk when creating a new log segment within a topic.

Link copied to clipboard
val retentionBytes: Output<String>? = null

The maximum size, in bytes, of a topic before messages are deleted. -1 is a special setting indicating that this setting has no limit.

Link copied to clipboard
val retentionMs: Output<String>? = null

The maximum time, in ms, that a topic log file is retained before deleting it. -1 is a special setting indicating that this setting has no limit.

Link copied to clipboard
val segmentBytes: Output<String>? = null

The maximum size, in bytes, of a single topic log file.

Link copied to clipboard
val segmentIndexBytes: Output<String>? = null

The maximum size, in bytes, of the offset index.

Link copied to clipboard
val segmentJitterMs: Output<String>? = null

The maximum time, in ms, subtracted from the scheduled segment disk flush time to avoid the thundering herd problem for segment flushing.

Link copied to clipboard
val segmentMs: Output<String>? = null

The maximum time, in ms, before the topic log will flush to disk.

Functions

Link copied to clipboard
open override fun toJava(): DatabaseKafkaTopicConfigArgs