public class Kafka10AdminUtilsOperation extends Object implements AdminUtilsOperation
Constructor and Description |
---|
Kafka10AdminUtilsOperation() |
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)
AdminUtilsOperation
AdminUtils.addPartitions(kafka.utils.ZkUtils, java.lang.String, int, java.lang.String, boolean)
invokeAddPartitions
in interface AdminUtilsOperation
zkUtils
- Zookeeper utilstopic
- name of the topicpublic short errorCodeFromTopicMetadata(String topic, kafka.utils.ZkUtils zkUtils)
AdminUtilsOperation
AdminUtils.fetchTopicMetadataFromZk(scala.collection.Set<java.lang.String>, kafka.utils.ZkUtils)
errorCodeFromTopicMetadata
in interface AdminUtilsOperation
topic
- namezkUtils
- zookeeper utilspublic int partitionSize(String topic, kafka.utils.ZkUtils zkUtils)
AdminUtilsOperation
AdminUtils
partitionSize
in interface AdminUtilsOperation
topic
- namezkUtils
- zookeeper utilspublic void invokeCreateTopic(kafka.utils.ZkUtils zkUtils, String topic, int partitions, int replicationFactor, Properties topicConfig)
AdminUtilsOperation
AdminUtils.createTopic(kafka.utils.ZkUtils, java.lang.String, int, int, java.util.Properties)
invokeCreateTopic
in interface AdminUtilsOperation
zkUtils
- zookeeper utilstopic
- nameCopyright © 2017 Pivotal Software, Inc.. All rights reserved.