public interface AdminUtilsOperation
AdminUtils to support
various versions of Kafka brokers.
Note: Implementations that support Kafka brokers other than 0.9, need to use
a possible strategy that involves reflection around AdminUtils.| 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 |
void invokeAddPartitions(kafka.utils.ZkUtils zkUtils,
String topic,
int numPartitions,
String replicaAssignmentStr,
boolean checkBrokerAvailable)
AdminUtils.addPartitions(kafka.utils.ZkUtils, java.lang.String, int, java.lang.String, boolean)zkUtils - Zookeeper utilstopic - name of the topicnumPartitions - replicaAssignmentStr - checkBrokerAvailable - short errorCodeFromTopicMetadata(String topic, kafka.utils.ZkUtils zkUtils)
AdminUtils.fetchTopicMetadataFromZk(scala.collection.Set<java.lang.String>, kafka.utils.ZkUtils)topic - namezkUtils - zookeeper utilsint partitionSize(String topic, kafka.utils.ZkUtils zkUtils)
AdminUtilstopic - namezkUtils - zookeeper utilsvoid invokeCreateTopic(kafka.utils.ZkUtils zkUtils,
String topic,
int partitions,
int replicationFactor,
Properties topicConfig)
AdminUtils.createTopic(kafka.utils.ZkUtils, java.lang.String, int, int, java.util.Properties)zkUtils - zookeeper utilstopic - namepartitions - replicationFactor - topicConfig - Copyright © 2016 Pivotal Software, Inc.. All rights reserved.