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)
AdminUtils
topic
- 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.