Managed Service for Apache Kafka® API, REST: Topic methods
A set of methods for managing Kafka topics.
JSON Representation
{
"name": "string",
"clusterId": "string",
"partitions": "integer",
"replicationFactor": "integer",
// includes only one of the fields `topicConfig_2_8`, `topicConfig_3`
"topicConfig_2_8": {
"cleanupPolicy": "string",
"compressionType": "string",
"deleteRetentionMs": "integer",
"fileDeleteDelayMs": "integer",
"flushMessages": "integer",
"flushMs": "integer",
"minCompactionLagMs": "integer",
"retentionBytes": "integer",
"retentionMs": "integer",
"maxMessageBytes": "integer",
"minInsyncReplicas": "integer",
"segmentBytes": "integer",
"preallocate": true
},
"topicConfig_3": {
"cleanupPolicy": "string",
"compressionType": "string",
"deleteRetentionMs": "integer",
"fileDeleteDelayMs": "integer",
"flushMessages": "integer",
"flushMs": "integer",
"minCompactionLagMs": "integer",
"retentionBytes": "integer",
"retentionMs": "integer",
"maxMessageBytes": "integer",
"minInsyncReplicas": "integer",
"segmentBytes": "integer",
"preallocate": true
},
// end of the list of possible fields
}
Field | Description |
---|---|
name | string Name of the topic. |
clusterId | string ID of an Apache Kafka® cluster that the topic belongs to. To get the Apache Kafka® cluster ID, make a list request. |
partitions | integer (int64) The number of the topic's partitions. |
replicationFactor | integer (int64) Amount of data copies (replicas) for the topic in the cluster. |
topicConfig_2_8 | object includes only one of the fields topicConfig_2_8 , topicConfig_3 A topic settings for 2.8 |
topicConfig_2_8. cleanupPolicy |
string Retention policy to use on old log messages.
|
topicConfig_2_8. compressionType |
string The compression type for a given topic.
|
topicConfig_2_8. deleteRetentionMs |
integer (int64) The amount of time in milliseconds to retain delete tombstone markers for log compacted topics. |
topicConfig_2_8. fileDeleteDelayMs |
integer (int64) The time to wait before deleting a file from the filesystem. |
topicConfig_2_8. flushMessages |
integer (int64) The number of messages accumulated on a log partition before messages are flushed to disk. This setting overrides the cluster-level |
topicConfig_2_8. flushMs |
integer (int64) The maximum time in milliseconds that a message in the topic is kept in memory before flushed to disk. This setting overrides the cluster-level |
topicConfig_2_8. minCompactionLagMs |
integer (int64) The minimum time in milliseconds a message will remain uncompacted in the log. |
topicConfig_2_8. retentionBytes |
integer (int64) The maximum size a partition can grow to before Kafka will discard old log segments to free up space if the This setting overrides the cluster-level |
topicConfig_2_8. retentionMs |
integer (int64) The number of milliseconds to keep a log segment's file before deleting it. This setting overrides the cluster-level |
topicConfig_2_8. maxMessageBytes |
integer (int64) The largest record batch size allowed in topic. |
topicConfig_2_8. minInsyncReplicas |
integer (int64) This configuration specifies the minimum number of replicas that must acknowledge a write to topic for the write to be considered successful (when a producer sets acks to "all"). |
topicConfig_2_8. segmentBytes |
integer (int64) This configuration controls the segment file size for the log. Retention and cleaning is always done a file at a time so a larger segment size means fewer files but less granular control over retention. This setting overrides the cluster-level |
topicConfig_2_8. preallocate |
boolean (boolean) True if we should preallocate the file on disk when creating a new log segment. This setting overrides the cluster-level |
topicConfig_3 | object includes only one of the fields topicConfig_2_8 , topicConfig_3 A topic settings for 3.x |
topicConfig_3. cleanupPolicy |
string Retention policy to use on old log messages.
|
topicConfig_3. compressionType |
string The compression type for a given topic.
|
topicConfig_3. deleteRetentionMs |
integer (int64) The amount of time in milliseconds to retain delete tombstone markers for log compacted topics. |
topicConfig_3. fileDeleteDelayMs |
integer (int64) The time to wait before deleting a file from the filesystem. |
topicConfig_3. flushMessages |
integer (int64) The number of messages accumulated on a log partition before messages are flushed to disk. This setting overrides the cluster-level |
topicConfig_3. flushMs |
integer (int64) The maximum time in milliseconds that a message in the topic is kept in memory before flushed to disk. This setting overrides the cluster-level |
topicConfig_3. minCompactionLagMs |
integer (int64) The minimum time in milliseconds a message will remain uncompacted in the log. |
topicConfig_3. retentionBytes |
integer (int64) The maximum size a partition can grow to before Kafka will discard old log segments to free up space if the This setting overrides the cluster-level |
topicConfig_3. retentionMs |
integer (int64) The number of milliseconds to keep a log segment's file before deleting it. This setting overrides the cluster-level |
topicConfig_3. maxMessageBytes |
integer (int64) The largest record batch size allowed in topic. |
topicConfig_3. minInsyncReplicas |
integer (int64) This configuration specifies the minimum number of replicas that must acknowledge a write to topic for the write to be considered successful (when a producer sets acks to "all"). |
topicConfig_3. segmentBytes |
integer (int64) This configuration controls the segment file size for the log. Retention and cleaning is always done a file at a time so a larger segment size means fewer files but less granular control over retention. This setting overrides the cluster-level |
topicConfig_3. preallocate |
boolean (boolean) True if we should preallocate the file on disk when creating a new log segment. This setting overrides the cluster-level |
Methods
Method | Description |
---|---|
create | Creates a new Kafka topic in the specified cluster. |
delete | Deletes the specified Kafka topic. |
get | Returns the specified Kafka topic. |
list | Retrieves the list of Kafka topics in the specified cluster. |
update | Updates the specified Kafka topic. |