public class Kafka09AdminUtilsOperation extends Object implements AdminUtilsOperation
| Constructor and Description |
|---|
Kafka09AdminUtilsOperation() |
| Modifier and Type | Method and Description |
|---|---|
short |
errorCodeFromTopicMetadata(String topic,
kafka.utils.ZkUtils zkUtils)
Invoke
AdminUtils.fetchTopicMetadataFromZk(scala.collection.Set<java.lang.String>, kafka.utils.ZkUtils) |
void |
invokeAddPartitions(kafka.utils.ZkUtils zkUtils,
String topic,
int numPartitions,
String replicaAssignmentStr,
boolean checkBrokerAvailable)
Invoke
AdminUtils.addPartitions(kafka.utils.ZkUtils, java.lang.String, int, java.lang.String, boolean) |
void |
invokeCreateTopic(kafka.utils.ZkUtils zkUtils,
String topic,
int partitions,
int replicationFactor,
Properties topicConfig)
Inovke
AdminUtils.createTopic(kafka.utils.ZkUtils, java.lang.String, int, int, java.util.Properties) |
int |
partitionSize(String topic,
kafka.utils.ZkUtils zkUtils)
Find partition size from Kafka broker using
AdminUtils |
public void invokeAddPartitions(kafka.utils.ZkUtils zkUtils,
String topic,
int numPartitions,
String replicaAssignmentStr,
boolean checkBrokerAvailable)
AdminUtilsOperationAdminUtils.addPartitions(kafka.utils.ZkUtils, java.lang.String, int, java.lang.String, boolean)invokeAddPartitions in interface AdminUtilsOperationzkUtils - Zookeeper utilstopic - name of the topicpublic short errorCodeFromTopicMetadata(String topic, kafka.utils.ZkUtils zkUtils)
AdminUtilsOperationAdminUtils.fetchTopicMetadataFromZk(scala.collection.Set<java.lang.String>, kafka.utils.ZkUtils)errorCodeFromTopicMetadata in interface AdminUtilsOperationtopic - namezkUtils - zookeeper utilspublic int partitionSize(String topic, kafka.utils.ZkUtils zkUtils)
AdminUtilsOperationAdminUtilspartitionSize in interface AdminUtilsOperationtopic - namezkUtils - zookeeper utilspublic void invokeCreateTopic(kafka.utils.ZkUtils zkUtils,
String topic,
int partitions,
int replicationFactor,
Properties topicConfig)
AdminUtilsOperationAdminUtils.createTopic(kafka.utils.ZkUtils, java.lang.String, int, int, java.util.Properties)invokeCreateTopic in interface AdminUtilsOperationzkUtils - zookeeper utilstopic - nameCopyright © 2016 Pivotal Software, Inc.. All rights reserved.