4 ' ' ' ' ' ' ' ' '  ' ' ' ' ' '   G  '  '  '  ' '  G #  ' ' ) '      '  '  '    '  ' ' '  ?  B  )  #    #  B  B ' S   B B ? B ? ? ?  ? ? \  '  e   '      #  # #      B  B ? ?  ) )                 ! "#$ %&'() * '+ ', '- . '/ '0 '1 '2 '3 '4PartitionMetadata InnerClasses TopicMetadataNO_CONTROLLER_IDI ConstantValueBROKERS ComplexArray;Lorg/apache/kafka/common/protocol/types/Field$ComplexArray;TOPIC_METADATA CLUSTER_ID NullableStr:Lorg/apache/kafka/common/protocol/types/Field$NullableStr; CONTROLLER_IDInt324Lorg/apache/kafka/common/protocol/types/Field$Int32;NODE_IDHOSTStr2Lorg/apache/kafka/common/protocol/types/Field$Str;PORTRACKPARTITION_METADATA IS_INTERNALBool3Lorg/apache/kafka/common/protocol/types/Field$Bool;LEADERREPLICASArray4Lorg/apache/kafka/common/protocol/types/Field$Array;ISROFFLINE_REPLICASMETADATA_BROKER_V0.Lorg/apache/kafka/common/protocol/types/Field;PARTITION_METADATA_V0TOPIC_METADATA_V0METADATA_RESPONSE_V0/Lorg/apache/kafka/common/protocol/types/Schema;METADATA_BROKER_V1TOPIC_METADATA_V1METADATA_RESPONSE_V1METADATA_RESPONSE_V2METADATA_RESPONSE_V3METADATA_RESPONSE_V4PARTITION_METADATA_V5TOPIC_METADATA_V5METADATA_RESPONSE_V5METADATA_RESPONSE_V6PARTITION_METADATA_V7TOPIC_METADATA_V7METADATA_RESPONSE_V7throttleTimeMsbrokersLjava/util/Collection; Signature6Ljava/util/Collection; controllerLorg/apache/kafka/common/Node; topicMetadataLjava/util/List;SLjava/util/List; clusterIdLjava/lang/String;schemaVersions2()[Lorg/apache/kafka/common/protocol/types/Schema;CodeLineNumberTable6(Ljava/util/List;Ljava/lang/String;ILjava/util/List;)VLocalVariableTablethis3Lorg/apache/kafka/common/requests/MetadataResponse; controllerIdLocalVariableTypeTable0Ljava/util/List;(Ljava/util/List;Ljava/lang/String;ILjava/util/List;)V7(ILjava/util/List;Ljava/lang/String;ILjava/util/List;)V(ILjava/util/List;Ljava/lang/String;ILjava/util/List;)V2(Lorg/apache/kafka/common/protocol/types/Struct;)Vbroker/Lorg/apache/kafka/common/protocol/types/Struct;nodeIdhostportrack brokerStructLjava/lang/Object; partitionInfopartitionError)Lorg/apache/kafka/common/protocol/Errors; partitionleader leaderEpochLjava/util/Optional; leaderNodereplicas[Ljava/lang/Object; replicaNodesisrisrNodesofflineReplicas offlineNodespartitionInfoObj topicInfo topicErrortopic isInternalZpartitionMetadatapartitionInfos topicInfoObjstructLjava/util/Map; brokerStructs topicInfos)Ljava/util/Optional;WLjava/util/List;BLjava/util/Map; StackMapTable56789:convertToNodes4(Ljava/util/Map;[Ljava/lang/Object;)Ljava/util/List;brokerId brokerIdsnodes(Ljava/util/Map;[Ljava/lang/Object;)Ljava/util/List;getControllerNode7(ILjava/util/Collection;)Lorg/apache/kafka/common/Node;;W(ILjava/util/Collection;)Lorg/apache/kafka/common/Node;()Ierrors()Ljava/util/Map;metadataALorg/apache/kafka/common/requests/MetadataResponse$TopicMetadata;LLjava/util/Map;N()Ljava/util/Map; errorCountsMLjava/util/Map;O()Ljava/util/Map; topicsByError:(Lorg/apache/kafka/common/protocol/Errors;)Ljava/util/Set;error errorTopicsLjava/util/Set;#Ljava/util/Set;<N(Lorg/apache/kafka/common/protocol/Errors;)Ljava/util/Set;unavailableTopics()Ljava/util/Set;ELorg/apache/kafka/common/requests/MetadataResponse$PartitionMetadata;invalidMetadataTopics%()Ljava/util/Set;cluster#()Lorg/apache/kafka/common/Cluster;internalTopics partitions9Ljava/util/List;()Ljava/util/Collection;8()Ljava/util/Collection;[()Ljava/util/Collection; ()Lorg/apache/kafka/common/Node;()Ljava/lang/String;parseK(Ljava/nio/ByteBuffer;S)Lorg/apache/kafka/common/requests/MetadataResponse;bufferLjava/nio/ByteBuffer;versionStoStruct2(S)Lorg/apache/kafka/common/protocol/types/Struct;nodeLjava/util/ArrayList; partitionData topicDatapartitionMetadataArray brokerArraytopicMetadataArray*Ljava/util/ArrayList;ALjava/util/List;shouldClientThrottle(S)Z()V SourceFileMetadataResponse.java-org/apache/kafka/common/protocol/types/Schema 1org/apache/kafka/common/requests/AbstractResponse   BC = > ?@ AFjava/util/HashMap BC-org/apache/kafka/common/protocol/types/Struct BD BE ?F GHorg/apache/kafka/common/Node I5 JK 1org/apache/kafka/common/requests/MetadataResponse java/util/ArrayList LO BPQ RS8 TU V ?W X YZ [\ B] B^ <= _^Corg/apache/kafka/common/requests/MetadataResponse$PartitionMetadata `6 ab?org/apache/kafka/common/requests/MetadataResponse$TopicMetadata c dc e fbjava/lang/Integer gh ij; kl mn oF pq r $g stjava/util/HashSet< uv7org/apache/kafka/common/errors/InvalidMetadataException wx yz {| }~%org/apache/kafka/common/PartitionInfo    [Lorg/apache/kafka/common/Node;   org/apache/kafka/common/Cluster  PQ            g  F g   F S  %l G ' F    9org/apache/kafka/common/protocol/types/Field$ComplexArray*Host and port information for all brokers. topic_metadataMetadata for requested topics8org/apache/kafka/common/protocol/types/Field$NullableStr cluster_id+The cluster id that this broker belongs to.2org/apache/kafka/common/protocol/types/Field$Int32 controller_id'The broker id of the controller broker.node_idThe broker id.0org/apache/kafka/common/protocol/types/Field$StrThe hostname of the broker..The port on which the broker accepts requests.The rack of the broker.partition_metadata)Metadata for each partition of the topic.1org/apache/kafka/common/protocol/types/Field$Bool is_internal;Indicates if the topic is considered a Kafka internal topic9The id of the broker acting as leader for this partition.2org/apache/kafka/common/protocol/types/Field$Array .The set of all nodes that host this partition. EThe set of nodes that are in sync with the leader for this partition.offline_replicas.The set of offline replicas of this partition.,org/apache/kafka/common/protocol/types/Field    java/util/Mapjava/util/Listjava/lang/Object'org/apache/kafka/common/protocol/Errorsjava/lang/Stringjava/util/Optionaljava/util/Iterator java/util/Set-org/apache/kafka/common/protocol/CommonFieldsTHROTTLE_TIME_MS getOrElseJ(Lorg/apache/kafka/common/protocol/types/Field$Int32;I)Ljava/lang/Integer;intValuegetP(Lorg/apache/kafka/common/protocol/types/Field$ComplexArray;)[Ljava/lang/Object;I(Lorg/apache/kafka/common/protocol/types/Field$Int32;)Ljava/lang/Integer;F(Lorg/apache/kafka/common/protocol/types/Field$Str;)Ljava/lang/String;`(Lorg/apache/kafka/common/protocol/types/Field$NullableStr;Ljava/lang/String;)Ljava/lang/String;valueOf(I)Ljava/lang/Integer;)(ILjava/lang/String;ILjava/lang/String;)Vput8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; ERROR_CODEInt164Lorg/apache/kafka/common/protocol/types/Field$Int16;G(Lorg/apache/kafka/common/protocol/types/Field$Int16;)Ljava/lang/Short;java/lang/Short shortValue()SforCode,(S)Lorg/apache/kafka/common/protocol/Errors; TOPIC_NAME7(Lorg/apache/kafka/common/protocol/types/Field$Bool;Z)Z PARTITION_ID LEADER_EPOCH-org/apache/kafka/common/requests/RequestUtilsgetLeaderEpochy(Lorg/apache/kafka/common/protocol/types/Struct;Lorg/apache/kafka/common/protocol/types/Field$Int32;)Ljava/util/Optional;&(Ljava/lang/Object;)Ljava/lang/Object;I(Lorg/apache/kafka/common/protocol/types/Field$Array;)[Ljava/lang/Object; getOrEmpty(Lorg/apache/kafka/common/protocol/Errors;ILorg/apache/kafka/common/Node;Ljava/util/Optional;Ljava/util/List;Ljava/util/List;Ljava/util/List;)Vadd(Ljava/lang/Object;)ZO(Lorg/apache/kafka/common/protocol/Errors;Ljava/lang/String;ZLjava/util/List;)Vvalues(I)V containsKey(ILjava/lang/String;I)Vjava/util/Collectioniterator()Ljava/util/Iterator;hasNext()Znext()Ljava/lang/Object;id access$000l(Lorg/apache/kafka/common/requests/MetadataResponse$TopicMetadata;)Lorg/apache/kafka/common/protocol/Errors;NONEupdateErrorCounts;(Ljava/util/Map;Lorg/apache/kafka/common/protocol/Errors;)V exception/()Lorg/apache/kafka/common/errors/ApiException; access$100U(Lorg/apache/kafka/common/requests/MetadataResponse$TopicMetadata;)Ljava/lang/String; access$200S(Lorg/apache/kafka/common/requests/MetadataResponse$TopicMetadata;)Ljava/util/List; access$300p(Lorg/apache/kafka/common/requests/MetadataResponse$PartitionMetadata;)Lorg/apache/kafka/common/protocol/Errors; access$400D(Lorg/apache/kafka/common/requests/MetadataResponse$TopicMetadata;)Z access$500H(Lorg/apache/kafka/common/requests/MetadataResponse$PartitionMetadata;)I access$600e(Lorg/apache/kafka/common/requests/MetadataResponse$PartitionMetadata;)Lorg/apache/kafka/common/Node; access$700W(Lorg/apache/kafka/common/requests/MetadataResponse$PartitionMetadata;)Ljava/util/List;toArray(([Ljava/lang/Object;)[Ljava/lang/Object; access$800 access$900(Ljava/lang/String;ILorg/apache/kafka/common/Node;[Lorg/apache/kafka/common/Node;[Lorg/apache/kafka/common/Node;[Lorg/apache/kafka/common/Node;)VTOPIC_AUTHORIZATION_FAILEDINVALID_TOPIC_EXCEPTION(Ljava/lang/String;Ljava/util/Collection;Ljava/util/Collection;Ljava/util/Set;Ljava/util/Set;Ljava/util/Set;Lorg/apache/kafka/common/Node;)V(org/apache/kafka/common/protocol/ApiKeysMETADATA*Lorg/apache/kafka/common/protocol/ApiKeys; parseResponseG(SLjava/nio/ByteBuffer;)Lorg/apache/kafka/common/protocol/types/Struct;responseSchema2(S)Lorg/apache/kafka/common/protocol/types/Schema;2(Lorg/apache/kafka/common/protocol/types/Schema;)V setIfExistsq(Lorg/apache/kafka/common/protocol/types/Field;Ljava/lang/Object;)Lorg/apache/kafka/common/protocol/types/Struct;instancel(Lorg/apache/kafka/common/protocol/types/Field$ComplexArray;)Lorg/apache/kafka/common/protocol/types/Struct;setf(Lorg/apache/kafka/common/protocol/types/Field$Int32;I)Lorg/apache/kafka/common/protocol/types/Struct;u(Lorg/apache/kafka/common/protocol/types/Field$Str;Ljava/lang/String;)Lorg/apache/kafka/common/protocol/types/Struct;()[Ljava/lang/Object;(Lorg/apache/kafka/common/protocol/types/Field$ComplexArray;[Ljava/lang/Object;)Lorg/apache/kafka/common/protocol/types/Struct;sizecodef(Lorg/apache/kafka/common/protocol/types/Field$Int16;S)Lorg/apache/kafka/common/protocol/types/Struct;java/lang/Boolean(Z)Ljava/lang/Boolean;()Ljava/util/List;leaderId access$1000[(Lorg/apache/kafka/common/requests/MetadataResponse$PartitionMetadata;)Ljava/util/Optional;setLeaderEpochIfExistsz(Lorg/apache/kafka/common/protocol/types/Struct;Lorg/apache/kafka/common/protocol/types/Field$Int32;Ljava/util/Optional;)Vx(Lorg/apache/kafka/common/protocol/types/Field$Array;[Ljava/lang/Object;)Lorg/apache/kafka/common/protocol/types/Struct;hasField1(Lorg/apache/kafka/common/protocol/types/Field;)Z'(Ljava/lang/String;Ljava/lang/String;)V+org/apache/kafka/common/protocol/types/TypeINT32DocumentedType%%%%%%%%  ! * *+ YM+N-:66a2::6 : 6  !: , "#Y    $%W+&6*+(!)Y*:++::66  1 2:  :  ,-./:  0:  126)Y*: 3::662::,-./:465667:,"8#:9::*,;:<::*,;:=>:*,;: ?Y @AWDBY  CAW *,D**,D*,#<CPZgr 18HUbl    L!CJ  P= Z3 g& r <Q8 HUbzlpVLC90& 1!"  # $ %& '(!)   * +#,kb-Hlp.C0   '/0k1.23455d6 2345655X23456557389655R23456557389655738:M;]2345655738965234565<=a)Y,EN,:66F2:+F-+8AW-#YGHIAW- !#".#@%Y!_&4#6>aa+a? W@a0 W@1&24565*7ABC,,JN-K-L#:M*+$,'-*.*  ,,, ,1 DEF/* 3 GHCYL*NM,K),LBN-OP+-Q-O%W+;<%=/>>?A@ %IJC;G+ ;GK14D+LMH3YL*NM,K,LBN*+-OR+EF%G1H % IJ3+M+ +MN14DOPQ@SYTM*NN-K&-LB:O+,QUW,OP&Q/R;S>T*&IJ@@R8ST 8SU1VD(WXY+SYTL*NM,Kk,LBN-OVW+-XUWC-YN:K.L?:ZVW+-XUWΧ+. ^_%`2a@cadoezf}hjk*a'Z%[J}[T }[U1VD-\ D1]^_ SYTL)Y*M*NN-K-LB:OP[+XUWYN:KbL?:,\YX]^_#`ab#`ac#`adAWXeY**,*fg*hg+*iRstu.v9wAxMyozv{{|}~z4oP'Z.IJ`Ta`Uab1 V6D2\ Dhc/* dc/* ef/* g/*  hiD'Yj*kljklmnoYjmnM,* "oW)Y*N*J:K\L#:,p:MqWrsWtqW uoW-AW,-vwW,&* *M"oW,(*oW)Y*xE:*N:KLB:,+p:0XsW,OyzW1{|oW)YYxE:}N:  Kg L?: 3p:  , ZyzW 4 ]qW 5 ~qW 6 )Y _xE:  _N:  K  L#: M"W 9 W)Y bxE:  bN:K L#: M"W < W =W)Y cxE: cN:K L#:M"W =W AW3vwWAW ,+vwW,/ !"&#G$P%^&l'z)*+,/245678&:7<J=l>v?@ADFGHIJK9LJMXNcOvPQRTVWXYZ[PA  GJpp9ppvAqvKr q q lU'Z s JtIJlm* &uv>vAww w Jtx&uxvx1136Db2363y2363y/6Dm 2366D\36Dx2366D\36Dz3{D&,{D&7{D& 2366D\362366|}K `  lm1 @~&YY+Y(Y&YYYY Y3Y1Y5Y9Y<Y=YSYSYS3Y,SY4SY5SY9SY