Versions Compared

Old Version 4

changes.mady.by.user Tom Bentley

Saved on

compared with

New Version 5

changes.mady.by.user Tom Bentley

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.
Comment: alterReplicationCount()

...

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()

...