Versions in this module Expand all Collapse all v0 v0.2.0 Aug 11, 2017 Changes in this version + type KafkaUtil struct + BrokerList []string + ClusterName string + KafkaClient sarama.Client + KazooClient *kazoo.Kazoo + func New(clusterSpec spec.Kafkacluster) (*KafkaUtil, error) + func (k *KafkaUtil) AllTopicsInSync() (bool, error) + func (k *KafkaUtil) CreateTopic(topicSpec spec.KafkaTopicSpec) error + func (k *KafkaUtil) GetPartitions(topic string) ([]int32, error) + func (k *KafkaUtil) GetTopicConfiguration(cluster spec.Kafkacluster) ([]spec.KafkaTopic, error) + func (k *KafkaUtil) GetTopicsOnBroker(cluster spec.Kafkacluster, brokerId int32) ([]string, error) + func (k *KafkaUtil) ListTopics() ([]string, error) + func (k *KafkaUtil) PrintFullStats() error + func (k *KafkaUtil) RemoveTopicFromBrokers(cluster spec.Kafkacluster, brokerToDelete int32, topic string) error + func (k *KafkaUtil) RemoveTopicsFromBrokers(cluster spec.Kafkacluster, brokerToDelete int32) error