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 |
...