Anzahl der Partitionen im Producer in kafka 0.8.0 mit Partitionen ermittelnFür Methode

Question

Haben wir eine Unterstützung für partitionsFor Methode im Hersteller in kafka Version 0.8.0? Ich möchte diese Methode verwenden, um die Anzahl der Partitionen eines kafka-Themas zu ermitteln.

Wenn diese Methode in kafka 0.8.0 nicht verfügbar ist, wie kann man die Anzahl der Partitionen im Producer in dieser speziellen Version von kafka am einfachsten ermitteln?

Answer 1

Sie können listTopics() -Methode auch

ArrayList<Topics> topicList = new ArrayList<Topics>(); 
    Properties props = new Properties(); 
    Map<String, List<PartitionInfo>> topics; 
    Topics topic; 
    InputStream input = 
getClass().getClassLoader().getResourceAsStream("kafkaCluster.properties"); 
    try { 
     props.load(input); 
     props.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, 
props.getProperty("BOOTSTRAP_SERVERS_CONFIG")); 
     props.put("key.deserializer", 
"org.apache.kafka.common.serialization.StringDeserializer"); 
     props.put("value.deserializer", 
"org.apache.kafka.common.serialization.StringDeserializer"); 
     KafkaConsumer<String, String> consumer = new KafkaConsumer<String, 
    String>(props); 
     topics = consumer.listTopics(); 
     // System.out.println(topics.get(topics)); 
     for (Map.Entry<String, List<PartitionInfo>> entry : 
    topics.entrySet()) { 
      System.out.println("Key = " + entry.getKey() + ", Value = " + 
    entry.getValue()); 
      topic = new Topics(); 
      topic.setTopic_name(entry.getKey()); 
      topic.setPartitions(Integer.toString(entry.getValue().size())); 
      topicList.add(topic); 
     } 
    } catch (IOException e) { 
     e.printStackTrace(); 
    } 

Answer 2

Warum versuchen Sie nicht folgenden Ansatz https://stackoverflow.com/a/35458605/5922904. Auch ZkUtils haben die Methode getPartitionsForTopics, die auch verwendet werden kann. Obwohl ich noch nicht ausprobiert und getestet, es selbst