本文整理了Java中kafka.utils.ZkUtils.formatAsReassignmentJson()方法的一些代码示例，展示了ZkUtils.formatAsReassignmentJson()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZkUtils.formatAsReassignmentJson()方法的具体详情如下：
包路径：kafka.utils.ZkUtils
类名称：ZkUtils
方法名：formatAsReassignmentJson

ZkUtils.formatAsReassignmentJson介绍

暂无

代码示例

代码示例来源：origin: SiftScience/kafka-assigner

private static void printCurrentAssignment(ZkUtils zkUtils, List<String> specifiedTopics) {
  Seq<String> topics = specifiedTopics != null ?
      JavaConversions.iterableAsScalaIterable(specifiedTopics).toSeq() :
      zkUtils.getAllTopics();
  System.out.println("CURRENT ASSIGNMENT:");
  System.out.println(
      zkUtils.formatAsReassignmentJson(zkUtils.getReplicaAssignmentForTopics(
          topics)));
}

代码示例来源：origin: gnuhpc/Kafka-zk-restapi

public List<String> generateReassignPartition(ReassignWrapper reassignWrapper) {
 Seq brokerSeq =
   JavaConverters.asScalaBufferConverter(reassignWrapper.getBrokers()).asScala().toSeq();
 // <Proposed partition reassignment，Current partition replica assignment>
 Tuple2 resultTuple2 =
   ReassignPartitionsCommand.generateAssignment(
     zkUtils, brokerSeq, reassignWrapper.generateReassignJsonString(), false);
 List<String> result = new ArrayList<>();
 result.add(
   zkUtils.formatAsReassignmentJson(
     (scala.collection.Map<TopicAndPartition, Seq<Object>>) resultTuple2._2()));
 result.add(
   zkUtils.formatAsReassignmentJson(
     (scala.collection.Map<TopicAndPartition, Seq<Object>>) resultTuple2._1()));
 return result;
}

代码示例来源：origin: pinterest/doctorkafka

scala.collection.Map<TopicAndPartition, Seq<Object>> proposedAssignment =
  getAssignmentPlan(replicasMap);
String jsonReassignmentData = ZkUtils.formatAsReassignmentJson(proposedAssignment);

代码示例来源：origin: pinterest/doctorkafka

scala.collection.Map<TopicAndPartition, Seq<Object>> proposedAssignment =
   getAssignmentPlan(assignmentPlan);
 String jsonReassignmentData = ZkUtils.formatAsReassignmentJson(proposedAssignment);
 return jsonReassignmentData;
} else {