Kafka, wie die neueste erstellte Partition ID für ein Thema in Java zu kennen ist

Question

Ich erstelle Partition für ein Thema dynamisch mit AdminUtils. Ich muss die PartitionId der neu erstellten Partition abrufen, um sie in Mysql für meine Geschäftslogik zu speichern. Wie kann ich das erreichen? Mein aktueller Code:

AdminUtils.addPartitions(zkUtils,KAFKA_PRODUCER_TOPIC,currentPartitionCount+1,"",true); 

      List<PartitionInfo> infoList = producer.partitionsFor(KAFKA_PRODUCER_TOPIC); 
      for(PartitionInfo info : infoList){ 
       System.out.println(info.partition()); 
      } 
      createdPartionId = infoList.get(0).partition(); 

Problem oben ist, dass letzte erstellte Partition nicht in der Partition Liste kommt. Ich weiß nicht warum. Producer ist die Kafka Producer API.

Answer 1

Sie können eine TopicMetadataRequest tun. Siehe the example. Sie können dies vorher und nachher tun und die Ergebnisse vergleichen. Andernfalls wird die neue Partition immer mit einem newPartitionID == previousLastPartitionID + 1

hinzugefügt