AdminUtils
to support
various versions of Kafka brokers.AdminUtils.fetchTopicMetadataFromZk(scala.collection.Set<java.lang.String>, kafka.utils.ZkUtils)
AdminUtils.addPartitions(kafka.utils.ZkUtils, java.lang.String, int, java.lang.String, boolean)
AdminUtils.createTopic(kafka.utils.ZkUtils, java.lang.String, int, int, java.util.Properties)
Binder
that uses Kafka as the underlying middleware.Binder
for Kafka.AdminUtils
Copyright © 2016 Pivotal Software, Inc.. All rights reserved.