THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||||
---|---|---|---|---|---|---|
| ||||||
public class AdminClient { /** * A producer is instantiated by providing a set of key-value pairs as configuration. Most * of the settings will be related to NetworkClient * * @param properties settings related to Network client and at least one broker from KafkaCluster to connect to */ public AdminClient(Properties properties) /** * Create topic with given number of partitions and replication factor, replica assignment will be handled by Kafka cluster * * @throws ApiException */ public void createTopic(String topicName, int partitions, int replicationFactor, List<ConfigEntry> configs) throws ApiException; /** * Create topic with specified replica assignment (number of partitions and replication factor will be taken * from replica assignment string) * * @throws ApiException */ public void createTopic(String topicName, String replicaAssignment, List<ConfigEntry> configs) throws ApiException; /** * Alter existing topic partitions and/or replica assignment among Kafka brokers * * @throws ApiException */ public abstract void alterTopic(String topicName, Integer partitions, String replicaAssignment, List<ConfigEntry> addedConfigs, List<String> deletedConfigs) throws ApiException; /** * Delete Kafka topic by name * * @throws ApiException */ public abstract void deleteTopic(String topicName) throws ApiException; /** * List all existing topics in Kafka cluster * * @throws ApiException */ public abstract List<String> listTopics() throws ApiException; /** * Request replication information about Kafka topic * * @throws ApiException */ public abstract DescribeTopicOutput describeTopic(String topicName) throws ApiException; /** * Initiate long-running reassign partitions procedure * * @param partitionsReassignment manual partitions assignment string (according to ReassignPartitionsCommand) * @return future of the reassignment result which is completed once server-side partitions reassignment has succeeded or * an error occurred so that partitions reassignment cannot be started * @throws ApiException */ public abstract Future<ReassignPartitionsResponse> reassignPartitions(String partitionsReassignment) throws ApiException; /** * Check the interim status of the partitions reassignment * * @param partitionsReassignment manual partitions assignment string (according to ReassignPartitionsCommand) * @return partition to reassignment result code (completed, in-progress, failed) * @throws ApiException */ public abstract Map<TopicPartition, Short> verifyReassignPartitions(String partitionsReassignment) throws ApiException; /** * Initiate long-running preferred replica leader election procedure * * @param partitions serialized partitions for which preferred replica leader election will be started * (according to PreferredReplicaLeaderElectionCommand) * @return future of the election result which is completed once server-side preferred replica is elected for provided partitions or * an error has occurred * @throws ApiException */ public abstract Future<PreferredReplicaLeaderElectionResponse> preferredReplicaLeaderElection(String partitions) throws ApiException; /** * Check the interim status of the preferred replica leader election * * @param partitions for which preferred replica leader election was started (according to PreferredReplicaLeaderElectionCommand) * @return partition to reassignment result code (completed, in-progress, failed) * @throws ApiException */ public abstract VerifyPreferredReplicaLeaderElectionResponse verifyPreferredReplicaLeaderElection(String partitions) throws ApiException; /** * SendA generic facility to send Admin request and return response counterpart * * @param adminRequest AbstractAdminRequestAdminRequest subtypemessage * @param <T> concrete AdminRequest AdminRequestTypetype * @return response counterpart * @throws ApiException */ private <T extends AbstractAdminResponse> T sendAdminRequest(AbstractAdminRequest<T> adminRequest) throws ApiException; /** * Refreshes cluster metadata cache - list of brokers and controller * * @throws ApiException */ private void updateClusterMetadata() throws Exception; } |
...