4 _          > # #  u      1  1 #   # > > >      E  ?   4 G    ! Q" R# R$% & Q'() *+,-Builder InnerClassesTOPIC_PARTITIONS_KEY_NAMELjava/lang/String; ConstantValueNEW_PARTITIONS_KEY_NAMECOUNT_KEY_NAMEASSIGNMENT_KEY_NAMETIMEOUT_KEY_NAMEVALIDATE_ONLY_KEY_NAMECREATE_PARTITIONS_REQUEST_V0/Lorg/apache/kafka/common/protocol/types/Schema;CREATE_PARTITIONS_REQUEST_V1 duplicatesLjava/util/Set; Signature#Ljava/util/Set; newPartitionsLjava/util/Map;QLjava/util/Map;timeoutI validateOnlyZschemaVersions2()[Lorg/apache/kafka/common/protocol/types/Schema;CodeLineNumberTable(Ljava/util/Map;IZS)VLocalVariableTablethis:Lorg/apache/kafka/common/requests/CreatePartitionsRequest; apiVersionSLocalVariableTypeTableW(Ljava/util/Map;IZS)V3(Lorg/apache/kafka/common/protocol/types/Struct;S)VbrokerLjava/lang/Object; replicasArray[Ljava/lang/Object; replicasListLjava/util/List;replicas assignments newPartition.Lorg/apache/kafka/clients/admin/NewPartitions;topicPartitionCountStruct/Lorg/apache/kafka/common/protocol/types/Struct;topicpartitionCountStructcountassignmentsArraydupetopicPartitionCountObjstructtopicCountArraycountsdupes%Ljava/util/List;7Ljava/util/List;>; StackMapTable./ ()Ljava/util/Set;%()Ljava/util/Set;()Ljava/util/Map;S()Ljava/util/Map;()I()ZtoStruct1()Lorg/apache/kafka/common/protocol/types/Struct;partitionAssignmenti[[Ljava/lang/Object;topicPartitionCountEntryLjava/util/Map$Entry;topicPartitionsListWLjava/util/Map$Entry;ALjava/util/List;0getErrorResponseK(ILjava/lang/Throwable;)Lorg/apache/kafka/common/requests/AbstractResponse;throttleTimeMseLjava/lang/Throwable; topicErrors versionIdNLjava/util/Map;parseR(Ljava/nio/ByteBuffer;S)Lorg/apache/kafka/common/requests/CreatePartitionsRequest;bufferLjava/nio/ByteBuffer;version()V SourceFileCreatePartitionsRequest.java-org/apache/kafka/common/protocol/types/Schema kl ml1 23 }4 rs5 6 no uv wx8org/apache/kafka/common/requests/CreatePartitionsRequesttopic_partitions 78java/util/HashMap }9java/util/HashSet }-org/apache/kafka/common/protocol/types/Struct: ;> ?@new_partitions AB CD E assignmentjava/util/ArrayList FGjava/lang/Integer HI HJ. KL,org/apache/kafka/clients/admin/NewPartitions/ validate_only MNO P Q RS }T U VW0 X YZjava/util/Map$Entry [B \Zjava/lang/String ]^ _Z ` ab ]c d ejava/util/Listjava/lang/Object fg ah ij kl9org/apache/kafka/common/requests/CreatePartitionsResponse }m"java/lang/IllegalArgumentException:Version %d is not valid. Valid versions for %s are 0 to %dn ao pqr st uQ vw }x yz },org/apache/kafka/common/protocol/types/Field.org/apache/kafka/common/protocol/types/ArrayOf{ |The new partition count. } } The assigned brokers. } }3List of topic and the corresponding new partitions.8The time in ms to wait for the partitions to be created. XIf true then validate the request, but don't actually increase the number of partitions.0org/apache/kafka/common/requests/AbstractRequest@org/apache/kafka/common/requests/CreatePartitionsRequest$Builder java/util/Map java/util/Setjava/util/Iterator(org/apache/kafka/common/protocol/ApiKeysCREATE_PARTITIONS*Lorg/apache/kafka/common/protocol/ApiKeys;.(Lorg/apache/kafka/common/protocol/ApiKeys;S)Vjava/util/CollectionsemptySetgetArray'(Ljava/lang/String;)[Ljava/lang/Object;(I)V-org/apache/kafka/common/protocol/CommonFields TOPIC_NAMEStr2Lorg/apache/kafka/common/protocol/types/Field$Str;getF(Lorg/apache/kafka/common/protocol/types/Field$Str;)Ljava/lang/String; getStructC(Ljava/lang/String;)Lorg/apache/kafka/common/protocol/types/Struct;getInt'(Ljava/lang/String;)Ljava/lang/Integer;intValueadd(Ljava/lang/Object;)Z increaseToA(ILjava/util/List;)Lorg/apache/kafka/clients/admin/NewPartitions;1(I)Lorg/apache/kafka/clients/admin/NewPartitions;put8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; getBoolean'(Ljava/lang/String;)Ljava/lang/Boolean;java/lang/Boolean booleanValue()S requestSchema2(S)Lorg/apache/kafka/common/protocol/types/Schema;2(Lorg/apache/kafka/common/protocol/types/Schema;)VentrySetiterator()Ljava/util/Iterator;hasNextnext()Ljava/lang/Object;instancegetKeysetu(Lorg/apache/kafka/common/protocol/types/Field$Str;Ljava/lang/String;)Lorg/apache/kafka/common/protocol/types/Struct;getValue totalCountvalueOf(I)Ljava/lang/Integer;U(Ljava/lang/String;Ljava/lang/Object;)Lorg/apache/kafka/common/protocol/types/Struct;()Ljava/util/List;sizetoArray(([Ljava/lang/Object;)[Ljava/lang/Object;(Z)Ljava/lang/Boolean;keySet)org/apache/kafka/common/requests/ApiError fromThrowableB(Ljava/lang/Throwable;)Lorg/apache/kafka/common/requests/ApiError;(ILjava/util/Map;)Vjava/lang/Short(S)Ljava/lang/Short;getClass()Ljava/lang/Class;java/lang/Class getSimpleName()Ljava/lang/String; latestVersionformat9(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;(Ljava/lang/String;)V parseRequestG(SLjava/nio/ByteBuffer;)Lorg/apache/kafka/common/protocol/types/Struct;+org/apache/kafka/common/protocol/types/TypeINT32DocumentedType:   ?@S 9W9W,W7+ ,?@9W+%* 89W+&* A9W+|b=EXdm}"f  8v Edmo=$   = G) :+{DYBN*C.:/04:-,D"W*)6$EY-FGYH?YISY*JKSYLISMN|* .;>D`jx>. dvsDU %! {E Y*OP|{YQYQY RYYQYSYQYYQYQYSTUSYQYRYSVWXUSYZSYV[USYQY%S\USYQY&]^USY|1U7Bb"` a 1 <Q= }~