THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
/** * Change the partition count of the topics given as the keys of {@code counts} * to the corresponding values. Currently it is only possible to increase * the partition count. */ public AlterPartitionCountsResult alterPartitionCounts(Map<String, Integer> counts, AlterPartitionCountsOptions options) // where public AlterPartitionCountsResult alterPartitionCounts(Map<String, Integer> counts) |
Where:
Code Block |
---|
public class AlterPartitionCountsOptions { // TODO validateOnly? // TODO timeout? public AlterPartitionCountsOptions() { ... } class AlterPartitionCountsResult { public Map<String, KafkaFuture<Void>> values(); } |
Where:
Code Block |
---|
class AlterPartitionCountsOptions { // TODO validateOnly? // TODO timeout?Integer timeoutMs() { ... } public AlterPartitionCountsOptions timeoutMs(Integer timeoutMs) { ... } } public class AlterPartitionCountsResult { // package access constructor Map<String, KafkaFuture<Void>> values();() { ... } KafkaFuture<Void> all() { ... } } |
AdminClient: alterReplicationCount()
...
Code Block |
---|
/** * Change the replication factor of the topics given as the keys of * replicationFactors to the corresponding values. */ AlterReplicationFactorsResult alterReplicationFactors(Map<String, Short> replicationFactors) AlterReplicationFactorsResult alterReplicationFactors(Map<String, Short> replicationFactors, AlterReplicationFactorsOptions options) |
Where:
Code Block |
---|
public class AlterReplicationFactorsOptions { public AlterReplicationFactorsOptions() { ... } // TODO validateOnly? public // TODO timeout? } Integer timeoutMs() { ... } public AlterReplicationFactorsOptions timeoutMs(Integer timeoutMs) { ... } } public class AlterReplicationFactorsResult { Map<String, KafkaFuture<Void>> values(); { ... } KafkaFuture<Void> all() { ... } } |
AdminClient: reassignPartitions()
...