4R CD E F G H I JK L M N O PQ RST UV WX Y WZ [ \] ^_` ab cde Rf gh 'ij )k lmn ,Rop q rst Au 4vw 7x ydz{ | }~ r r A  J    l l y    O )  )  O ' N    c   ' y 7 7 c 4 4 c c 4 r } 4 A 7  n s  J  q J   {      {             InnerClassesEndPointBrokerPartitionStateBuilderCONTROLLER_ID_KEY_NAMELjava/lang/String; ConstantValueCONTROLLER_EPOCH_KEY_NAMEPARTITION_STATES_KEY_NAMELIVE_BROKERS_KEY_NAMELEADER_KEY_NAMELEADER_EPOCH_KEY_NAME ISR_KEY_NAMEZK_VERSION_KEY_NAMEREPLICAS_KEY_NAMEOFFLINE_REPLICAS_KEY_NAMEBROKER_ID_KEY_NAMEENDPOINTS_KEY_NAME RACK_KEY_NAME HOST_KEY_NAME PORT_KEY_NAMELISTENER_NAME_KEY_NAMESECURITY_PROTOCOL_TYPE_KEY_NAME*UPDATE_METADATA_REQUEST_PARTITION_STATE_V0/Lorg/apache/kafka/common/protocol/types/Schema;!UPDATE_METADATA_REQUEST_BROKER_V0UPDATE_METADATA_REQUEST_V0*UPDATE_METADATA_REQUEST_PARTITION_STATE_V1$UPDATE_METADATA_REQUEST_END_POINT_V1!UPDATE_METADATA_REQUEST_BROKER_V1UPDATE_METADATA_REQUEST_V1*UPDATE_METADATA_REQUEST_PARTITION_STATE_V2$UPDATE_METADATA_REQUEST_END_POINT_V2!UPDATE_METADATA_REQUEST_BROKER_V2UPDATE_METADATA_REQUEST_V2*UPDATE_METADATA_REQUEST_PARTITION_STATE_V3*UPDATE_METADATA_REQUEST_PARTITION_STATE_V4$UPDATE_METADATA_REQUEST_END_POINT_V3!UPDATE_METADATA_REQUEST_BROKER_V3UPDATE_METADATA_REQUEST_V3UPDATE_METADATA_REQUEST_V4 controllerIdIcontrollerEpochpartitionStatesLjava/util/Map; SignatureLjava/util/Map; liveBrokersLjava/util/Set;PLjava/util/Set;schemaVersions2()[Lorg/apache/kafka/common/protocol/types/Schema;CodeLineNumberTable$(SIILjava/util/Map;Ljava/util/Set;)VLocalVariableTablethis8Lorg/apache/kafka/common/requests/UpdateMetadataRequest;versionSLocalVariableTypeTable(SIILjava/util/Map;Ljava/util/Set;)V3(Lorg/apache/kafka/common/protocol/types/Struct;S)VrLjava/lang/Object;offlineReplicasArray[Ljava/lang/Object;partitionStateData/Lorg/apache/kafka/common/protocol/types/Struct;topic partitionleader leaderEpochisrArrayisrLjava/util/List; zkVersion replicasArrayreplicasofflineReplicaspartitionStateGLorg/apache/kafka/common/requests/UpdateMetadataRequest$PartitionState;partitionStateDataObjhostport endPointssecurityProtocol8Lorg/apache/kafka/common/security/auth/SecurityProtocol; listenerName endPointDataprotocolTypeIdendPointDataObjrack brokerDatabrokerId brokerDataObjstruct versionId%Ljava/util/List;SLjava/util/List; StackMapTableSVtoStruct1()Lorg/apache/kafka/common/protocol/types/Struct;topicPartition(Lorg/apache/kafka/common/TopicPartition;entryEntryLjava/util/Map$Entry;endPointALorg/apache/kafka/common/requests/UpdateMetadataRequest$EndPoint; endPointsDatabroker?Lorg/apache/kafka/common/requests/UpdateMetadataRequest$Broker;partitionStatesData brokersDataLjava/util/Map$Entry;ALjava/util/List;jhwtgetErrorResponseK(ILjava/lang/Throwable;)Lorg/apache/kafka/common/requests/AbstractResponse;throttleTimeMseLjava/lang/Throwable;()I()Ljava/util/Map;()Ljava/util/Map;()Ljava/util/Set;R()Ljava/util/Set;parseP(Ljava/nio/ByteBuffer;S)Lorg/apache/kafka/common/requests/UpdateMetadataRequest;bufferLjava/nio/ByteBuffer;^(SIILjava/util/Map;Ljava/util/Set;Lorg/apache/kafka/common/requests/UpdateMetadataRequest$1;)Vx0x1x2x3x4x5:Lorg/apache/kafka/common/requests/UpdateMetadataRequest$1;()V SourceFileUpdateMetadataRequest.java -org/apache/kafka/common/protocol/types/Schema    java/util/HashMap @6org/apache/kafka/common/requests/UpdateMetadataRequestpartition_states -org/apache/kafka/common/protocol/types/Struct     .controller_epoch  leader_epochjava/util/ArrayList java/lang/Integer  zk_versionoffline_replicas Eorg/apache/kafka/common/requests/UpdateMetadataRequest$PartitionState &org/apache/kafka/common/TopicPartition  java/util/HashSet live_brokersid   ?org/apache/kafka/common/requests/UpdateMetadataRequest$EndPoint    =org/apache/kafka/common/requests/UpdateMetadataRequest$Broker   end_pointssecurity_protocol_type    listener_name ,org/apache/kafka/common/network/ListenerName  controller_id      . 1  ! "# $%java/util/Map$Entry &' (% ) * . + ,% -./ 01 p 2 p 3 4 5) 7org/apache/kafka/common/requests/UpdateMetadataResponse6 78 9"java/lang/IllegalArgumentException:Version %d is not valid. Valid versions for %s are 0 to %djava/lang/Object :;< =) > ?@ AB ,org/apache/kafka/common/protocol/types/FieldC DGThe controller epoch. HThe broker id for the leader.The leader epoch..org/apache/kafka/common/protocol/types/ArrayOf IThe in sync replica ids.The ZK version.The replica ids. J The broker id. KGThe hostname of the broker..The port on which the broker accepts requests. The controller id. L MGThe security protocol type. NGThe rack The offline replica ids The listener name. 0org/apache/kafka/common/requests/AbstractRequest8org/apache/kafka/common/requests/UpdateMetadataRequest$1>org/apache/kafka/common/requests/UpdateMetadataRequest$Builder java/util/Mapjava/lang/Stringjava/util/List java/util/Set6org/apache/kafka/common/security/auth/SecurityProtocoljava/util/Iterator(org/apache/kafka/common/protocol/ApiKeysUPDATE_METADATA*Lorg/apache/kafka/common/protocol/ApiKeys;.(Lorg/apache/kafka/common/protocol/ApiKeys;S)VgetArray'(Ljava/lang/String;)[Ljava/lang/Object;-org/apache/kafka/common/protocol/CommonFields TOPIC_NAMEOStr2Lorg/apache/kafka/common/protocol/types/Field$Str;getF(Lorg/apache/kafka/common/protocol/types/Field$Str;)Ljava/lang/String; PARTITION_IDPInt324Lorg/apache/kafka/common/protocol/types/Field$Int32;I(Lorg/apache/kafka/common/protocol/types/Field$Int32;)Ljava/lang/Integer;intValuegetInt'(Ljava/lang/String;)Ljava/lang/Integer;(I)Vadd(Ljava/lang/Object;)ZhasField(Ljava/lang/String;)Z7(IIILjava/util/List;ILjava/util/List;Ljava/util/List;)V(Ljava/lang/String;I)Vput8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; getString&(Ljava/lang/String;)Ljava/lang/String; PLAINTEXTforSecurityProtocolh(Lorg/apache/kafka/common/security/auth/SecurityProtocol;)Lorg/apache/kafka/common/network/ListenerName;|(Ljava/lang/String;ILorg/apache/kafka/common/security/auth/SecurityProtocol;Lorg/apache/kafka/common/network/ListenerName;)V&(ILjava/util/List;Ljava/lang/String;)VgetShort%(Ljava/lang/String;)Ljava/lang/Short;java/lang/Short shortValue()SforId;(S)Lorg/apache/kafka/common/security/auth/SecurityProtocol;name(Ljava/lang/String;)V requestSchema2(S)Lorg/apache/kafka/common/protocol/types/Schema;2(Lorg/apache/kafka/common/protocol/types/Schema;)VvalueOf(I)Ljava/lang/Integer;setU(Ljava/lang/String;Ljava/lang/Object;)Lorg/apache/kafka/common/protocol/types/Struct;sizeentrySetiterator()Ljava/util/Iterator;hasNext()Znext()Ljava/lang/Object;instanceC(Ljava/lang/String;)Lorg/apache/kafka/common/protocol/types/Struct;getKey()Ljava/lang/String;u(Lorg/apache/kafka/common/protocol/types/Field$Str;Ljava/lang/String;)Lorg/apache/kafka/common/protocol/types/Struct;f(Lorg/apache/kafka/common/protocol/types/Field$Int32;I)Lorg/apache/kafka/common/protocol/types/Struct;getValuebasePartitionState5Lorg/apache/kafka/common/requests/BasePartitionState;3org/apache/kafka/common/requests/BasePartitionStatetoArray()[Ljava/lang/Object;(I)Ljava/lang/Object;(S)Ljava/lang/Short;.Lorg/apache/kafka/common/network/ListenerName;value'org/apache/kafka/common/protocol/Errors forException@(Ljava/lang/Throwable;)Lorg/apache/kafka/common/protocol/Errors;,(Lorg/apache/kafka/common/protocol/Errors;)VgetClass()Ljava/lang/Class;java/lang/Class getSimpleName latestVersionformat9(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String; parseRequestG(SLjava/nio/ByteBuffer;)Lorg/apache/kafka/common/protocol/types/Struct;+org/apache/kafka/common/protocol/types/TypeINT32QDocumentedType * YN+:66V2::: 6 6 6 6 :Y::662: !W"6#:Y::662: !WY$:%&9%::662: !W'Y   (:-)Y  *+W,Y-:+.:66E2::  /6  0&X 01:  26 Y: 3: 4Y  56!W7Y  89WƻY$:  ::  6 6 z 2::2601:;<=6>:?&?1: @: 4YAYB6!W:  C&  C1: 7Y   89W*+D *+ *- * ?'().*5+?,L-X.d/p1y2343689:;:= >?@6AC@ID`Ft)zIKLMPQRSTUVWXY;ZB[N\W]c^j`tacdYfghjKmnopq(  6 -5??5 L( X d p y k`.FI = 3 .}BcNWWNcBj;;j ( . " 5H k3        p        ,         '                 0              R       #           *E<YFGM,D* HIW,* HIWY* JN* KL:MNO:,P:Q):RSWTUWV':WXHIWWYHIWWZHIWW[\IW"W]HIW#W^\IW%&%_\IW-!W,-\IWY* `:* L:MN7:,.P:/aHIW3bc4:0dIW2eHIWYbf:bg:  Mj N4: :P:  2 eHIW 0 dIW ; hijIW ? klIW !W:\IWCmIW!W,.\IW,0uvw"x0zA{g|o}{~#5>AN` (;@PZ]lq~o{g O X AZ`; *g!"AZ"`; " t Q  #   #$ %&   )#a' #c( )*D*E>nY,opqYrsYjSY*tuSYvjSwx #=*DD+D,-? ./*  ./*  //*  01/*  2 34EY*yz567r */H 8 9 : ; < =>?@ Y{YSYSY{Y|}~SY{Y|~SY{Y|~SY{YY|~SY{Y"|~SY{Y#Y|~SY{Y{Y/|~SY{Y0~SY{Y2|~SY{Y{YD|~SY{Y|}~SY{YYSY{Y.YSY{Y{Y2|~SY{Y0~SY{Y;~SY{Y{Y/|~SY{Y:YSY{Y{YD|~SY{Y|}~SY{YYSY{Y.YSY{Y{Y/|~SY{Y:YSY{YC~SY{Y{YD|~SY{Y|}~SY{YYSY{Y.YSY {YSYSY{Y|}~SY{Y|~SY{Y|~SY{YY|~SY{Y"|~SY{Y#Y|~SY{Y%Y|~SY{Y{Y2|~SY{Y0~SY{Y?~SY{Y;~SY{Y{Y/|~SY{Y:YSY{YC~SY{Y{YD|~SY{Y|}~SY{YYSY{Y.YSY{Y{YD|~SY{Y|}~SY{YYSY{Y.YSFISX.^4aufjp rtXydXABJ 47' Ol { { EF