THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Code Block | ||||
|---|---|---|---|---|
| ||||
public class AlterPartitionCountsOptions {
public AlterPartitionCountsOptions() { ... }
public// TODO validateOnly?
public Integer timeoutMs() { ... }
public AlterPartitionCountsOptions timeoutMs(Integer timeoutMs) { ... }
}
public class AlterPartitionCountsResult {
// package access constructor
Map<String, KafkaFuture<Void>> values() { ... }
KafkaFuture<Void> all() { ... }
} |
...
| Code Block | ||||
|---|---|---|---|---|
| ||||
public class AlterReplicationFactorsOptions {
public AlterReplicationFactorsOptions() { ... }
// TODO validateOnly?
public Integer timeoutMs() { ... }
public AlterReplicationFactorsOptions timeoutMs(Integer timeoutMs) { ... }
}
public class AlterReplicationFactorsResult {
// package access constructor
Map<String Map<String, KafkaFuture<Void>> values() { ... }
KafkaFuture<Void> all() { ... }
} |
...
| No Format |
|---|
AlterPartitionCountsRequest => [topic_partition_count] timeout topic_partition_count => topic partition_count topic => STRING partition_count => INT32 timeout => INT32 // TODO: validate_only and/or timeout flags? |
Where
| Field | Description |
|---|---|
topic | the name of a topic |
partition_count | the new partition count |
timeout | The maximum time to await a response in ms. |
The request will require the ALTER operation on the Topic resource.
...
| Field | Description |
|---|---|
throttle_time_ms | duration in milliseconds for which the request was throttled |
topic | the name of a topic in the request |
error_code | an error code for that topic |
error_message | more detailed information about any error for that topic |
Anticipated errors:
CLUSTERTOPIC_AUTHORIZATION_FAILED(31) Authorization failed29) The user lacked Alter on the topicINVALID_TOPIC_EXCEPTION(17) If the topic doesn't existINVALID_PARTITIONS(37) If the num_partitions was invalidINVALID_REQUEST(42) If duplicate topics appeared in the request.NONE(0) The topic partition count was changed successfully.
...
| No Format |
|---|
AlterReplicationFactorsRequest => [topic_replication_factor] timeout topic_replication_factor => topic replication_factor topic => STRING replication_factor => INT16 timeout => INT32 // TODO: validate_only and/or timeout flags? |
Where
| Field | Description |
|---|---|
topic | topic name |
replication_factor | the new replication factor for this topic |
timeout | The maximum time to await a response in ms. |
The request will require the ClusterAction operation on the CLUSTER resource, since it can require significant inter-broker communication.
...
| No Format |
|---|
ReassignPartitionsRequest => [reassigned_topic] timeout validate_only reassigned_topic => topic [reassigned_partition] topic => STRING reassigned_partition => partitiodpartition_id [broker] partition_id => INT32 broker => INT32 timeout validate=> INT32 validate_only => BOOLEAN |
Where
| Field | Description |
|---|---|
topic | the name of a topic |
partition_id | a partition of that topic |
broker | a broker id |
timeout | The maximum time to await a response in ms. |
validate_only | when true: validate the request, but don't actually reassign the partitions |
...