4 %i ij kl mn o p q r s t u v w xy i z {| } ~ i            i  i i   0                  I  Ii Ni      U  U U  U    ]  ] e       i ]    v          {    J       v  v      ! " # $ %  e &'( InnerClassesLeaderAndEpochMetadataRequestAndVersionlogLorg/slf4j/Logger;refreshBackoffMsJmetadataExpireMs updateVersionIrequestVersion lastRefreshMslastSuccessfulRefreshMsfatalException(Lorg/apache/kafka/common/KafkaException; invalidTopicsLjava/util/Set; Signature#Ljava/util/Set;unauthorizedTopicscache(Lorg/apache/kafka/clients/MetadataCache; needUpdateZclusterResourceListeners;k(JJLorg/apache/kafka/common/utils/LogContext;Lorg/apache/kafka/common/internals/ClusterResourceListeners;)VCodeLineNumberTableLocalVariableTablethis#Lorg/apache/kafka/clients/Metadata; logContext*Lorg/apache/kafka/common/utils/LogContext;fetch#()Lorg/apache/kafka/common/Cluster;timeToAllowUpdate(J)JnowMstimeToNextUpdate timeToExpire StackMapTable()J requestUpdate()IupdateLastSeenEpochIfNewer,(Lorg/apache/kafka/common/TopicPartition;I)ZtopicPartition(Lorg/apache/kafka/common/TopicPartition; leaderEpochlastSeenLeaderEpoch>(Lorg/apache/kafka/common/TopicPartition;)Ljava/util/Optional;S(Lorg/apache/kafka/common/TopicPartition;)Ljava/util/Optional;updateLastSeenEpochK(Lorg/apache/kafka/common/TopicPartition;ILjava/util/function/Predicate;Z)Zepoch epochTestLjava/util/function/Predicate;setRequestUpdateFlagoldEpochLjava/lang/Integer;LocalVariableTypeTable3Ljava/util/function/Predicate;`(Lorg/apache/kafka/common/TopicPartition;ILjava/util/function/Predicate;Z)ZupdateRequested()ZpartitionInfoIfCurrentPartitionInfoAndEpoch~(Lorg/apache/kafka/common/TopicPartition;)Ljava/util/Optional; bootstrap(Ljava/util/List;J)V addressesLjava/util/List;now.Ljava/util/List;2(Ljava/util/List;J)Vupdate7(Lorg/apache/kafka/common/requests/MetadataResponse;J)Vresponse3Lorg/apache/kafka/common/requests/MetadataResponse;8(ILorg/apache/kafka/common/requests/MetadataResponse;J)VpreviousClusterIdLjava/lang/String;cluster!Lorg/apache/kafka/common/Cluster; newClusterId)*maybeSetMetadataError$(Lorg/apache/kafka/common/Cluster;)VcheckInvalidTopicscheckUnauthorizedTopicshandleMetadataResponse{(Lorg/apache/kafka/common/requests/MetadataResponse;Ljava/util/function/Predicate;)Lorg/apache/kafka/clients/MetadataCache;partitionMetadataPartitionMetadataELorg/apache/kafka/common/requests/MetadataResponse$PartitionMetadata;metadata TopicMetadataALorg/apache/kafka/common/requests/MetadataResponse$TopicMetadata;metadataResponsetopicsToRetaininternalTopics partitions brokersByIdaLjava/util/function/Predicate;PLjava/util/List;BLjava/util/Map;l+,-./0(Lorg/apache/kafka/common/requests/MetadataResponse;Ljava/util/function/Predicate;)Lorg/apache/kafka/clients/MetadataCache;updatePartitionInfox(Ljava/lang/String;Lorg/apache/kafka/common/requests/MetadataResponse$PartitionMetadata;ZLjava/util/function/Consumer;)Vinfo'Lorg/apache/kafka/common/PartitionInfo;newEpochtopichasReliableLeaderEpochpartitionInfoConsumerLjava/util/function/Consumer;tp]Ljava/util/function/Consumer;(Ljava/lang/String;Lorg/apache/kafka/common/requests/MetadataResponse$PartitionMetadata;ZLjava/util/function/Consumer;)VmaybeThrowAnyException()VmaybeThrowFatalExceptionmetadataExceptionmaybeThrowExceptionForTopic(Ljava/lang/String;)V!clearErrorsAndMaybeThrowException (Ljava/util/function/Supplier;)VrecoverableExceptionSupplierLjava/util/function/Supplier;GLjava/util/function/Supplier;J(Ljava/util/function/Supplier;)VrecoverableException*()Lorg/apache/kafka/common/KafkaException;recoverableExceptionForTopic<(Ljava/lang/String;)Lorg/apache/kafka/common/KafkaException;clearRecoverableErrors failedUpdate,(JLorg/apache/kafka/common/KafkaException;)VlastSuccessfulUpdatecloserequestUpdateForNewTopicsnewMetadataRequestAndVersion?()Lorg/apache/kafka/clients/Metadata$MetadataRequestAndVersion;newMetadataRequestBuilder2Builder<()Lorg/apache/kafka/common/requests/MetadataRequest$Builder; retainTopic(Ljava/lang/String;ZJ)Z isInternalleaderAndEpoch\(Lorg/apache/kafka/common/TopicPartition;)Lorg/apache/kafka/clients/Metadata$LeaderAndEpoch;lambda$leaderAndEpoch$6r(Lorg/apache/kafka/clients/MetadataCache$PartitionInfoAndEpoch;)Lorg/apache/kafka/clients/Metadata$LeaderAndEpoch; infoAndEpoch>Lorg/apache/kafka/clients/MetadataCache$PartitionInfoAndEpoch;leaderLorg/apache/kafka/common/Node;!$lambda$maybeThrowExceptionForTopic$5lambda$updatePartitionInfo$4(ILjava/lang/Integer;)Zlambda$handleMetadataResponse$3`(Ljava/util/Map;Ljava/util/List;Lorg/apache/kafka/clients/MetadataCache$PartitionInfoAndEpoch;)V partitionInfopartitionInfoWithoutLeaderpartitionInfoAndEpochlambda$update$2,(JLorg/apache/kafka/common/TopicPartition;)Zlambda$update$1E(JLorg/apache/kafka/common/requests/MetadataResponse$TopicMetadata;)Z#lambda$updateLastSeenEpochIfNewer$0 SourceFile Metadata.java 1 34 !org/apache/kafka/clients/Metadata5 67 java/util/HashMap 8 9: ; <= TopicPartition cannot be null> ?@BootstrapMethodsABCD EF / GHI JKjava/lang/IntegerDDetermining if we should replace existing epoch {} with new epoch {} LMN OP, EB7Updating last seen epoch from {} to {} for partition {}java/lang/Object QR STBNot replacing existing epoch {} with new epoch {} for partition {} U V WX Y  Metadata response cannot be null java/lang/IllegalStateException%Update requested after metadata close 6 * Z[\ ]^_` Ea    b:cd- ef ghCluster ID: {} %ij kl/Updated cluster metadata updateVersion {} to {} QP A1    : m,Metadata response reported invalid topics {} nijava/util/HashSet o :(Topic authorization failed for topics {}java/util/ArrayList+ p qrs tu0 v wx?org/apache/kafka/common/requests/MetadataResponse$TopicMetadata nyz {| O (^ }B  ~.Corg/apache/kafka/common/requests/MetadataResponse$PartitionMetadata   #$ 7org/apache/kafka/common/errors/InvalidMetadataException;Requesting metadata update for partition {} due to error {}&org/apache/kafka/common/TopicPartition  7Requesting metadata update for topic {} due to error {}&org/apache/kafka/clients/MetadataCache r |  |     Gx  G 78  G &org/apache/kafka/common/KafkaException:org/apache/kafka/common/errors/TopicAuthorizationException 4org/apache/kafka/common/errors/InvalidTopicException B ;org/apache/kafka/clients/Metadata$MetadataRequestAndVersion IL  L HS  0org/apache/kafka/clients/Metadata$LeaderAndEpoch   H _ V K ?@  gB%org/apache/kafka/common/PartitionInfoorg/apache/kafka/common/Node     MNjava/io/Closeable#org/apache/kafka/clients/Metadata$1java/lang/Stringorg/apache/kafka/common/Cluster1org/apache/kafka/common/requests/MetadataResponsejava/util/function/Predicate java/util/Setjava/util/List java/util/Mapjava/util/Iterator8org/apache/kafka/common/requests/MetadataRequest$Builderempty*()Lorg/apache/kafka/clients/MetadataCache;(org/apache/kafka/common/utils/LogContextlogger%(Ljava/lang/Class;)Lorg/slf4j/Logger;java/util/CollectionsemptySet()Ljava/util/Set;java/lang/Mathmax(JJ)Jjava/util/ObjectsrequireNonNull8(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; (Ljava/lang/Object;)Z (Ljava/lang/Integer;)Ztest!(I)Ljava/util/function/Predicate;get&(Ljava/lang/Object;)Ljava/lang/Object;java/util/Optional ofNullable((Ljava/lang/Object;)Ljava/util/Optional;valueOf(I)Ljava/lang/Integer;org/slf4j/Loggertrace9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)Vdebug((Ljava/lang/String;[Ljava/lang/Object;)Vput8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;getPartitionInfointValuegetPartitionInfoHavingEpoch?(Lorg/apache/kafka/common/TopicPartition;I)Ljava/util/Optional;:(Ljava/util/List;)Lorg/apache/kafka/clients/MetadataCache;clusterResource+()Lorg/apache/kafka/common/ClusterResource;'org/apache/kafka/common/ClusterResource clusterId()Ljava/lang/String; D(Lorg/apache/kafka/common/requests/MetadataResponse$TopicMetadata;)ZD(Lorg/apache/kafka/clients/Metadata;J)Ljava/util/function/Predicate;keySet +(Lorg/apache/kafka/common/TopicPartition;)ZremoveIf!(Ljava/util/function/Predicate;)Zequals'(Ljava/lang/Object;Ljava/lang/Object;)Z'(Ljava/lang/String;Ljava/lang/Object;)V:org/apache/kafka/common/internals/ClusterResourceListenersonUpdate,(Lorg/apache/kafka/common/ClusterResource;)VisEmptyerror(Ljava/util/Collection;)V()Ljava/util/Map; topicMetadata()Ljava/util/Collection;java/util/Collectioniterator()Ljava/util/Iterator;hasNextnext()Ljava/lang/Object;+()Lorg/apache/kafka/common/protocol/Errors;'org/apache/kafka/common/protocol/ErrorsNONE)Lorg/apache/kafka/common/protocol/Errors;add()Ljava/util/List;hasReliableLeaderEpochs(Ljava/lang/Object;)V A(Lorg/apache/kafka/clients/MetadataCache$PartitionInfoAndEpoch;)Vaccept>(Ljava/util/Map;Ljava/util/List;)Ljava/util/function/Consumer; exception/()Lorg/apache/kafka/common/errors/ApiException; partition(Ljava/lang/String;I)VvaluesTOPIC_AUTHORIZATION_FAILED topicsByError:(Lorg/apache/kafka/common/protocol/Errors;)Ljava/util/Set;INVALID_TOPIC_EXCEPTION controller ()Lorg/apache/kafka/common/Node;(Ljava/lang/String;Ljava/util/Collection;Ljava/util/Collection;Ljava/util/Set;Ljava/util/Set;Ljava/util/Set;Lorg/apache/kafka/common/Node;)V()Ljava/util/Optional; isPresent partitionMetaToInfo(Ljava/lang/String;Lorg/apache/kafka/common/requests/MetadataResponse$PartitionMetadata;)Lorg/apache/kafka/common/PartitionInfo;+(Lorg/apache/kafka/common/PartitionInfo;I)Vjava/util/function/Consumer ifPresent (Ljava/util/function/Consumer;)Vremove B(Lorg/apache/kafka/clients/Metadata;)Ljava/util/function/Supplier; T(Lorg/apache/kafka/clients/Metadata;Ljava/lang/String;)Ljava/util/function/Supplier; orElseGet1(Ljava/util/function/Supplier;)Ljava/lang/Object;(Ljava/util/Set;)Vcontains singleton#(Ljava/lang/Object;)Ljava/util/Set;c(Lorg/apache/kafka/common/requests/MetadataRequest$Builder;ILorg/apache/kafka/clients/Metadata$1;)V allTopics apply()Ljava/util/function/Function;map3(Ljava/util/function/Function;)Ljava/util/Optional;noNode5(Lorg/apache/kafka/common/Node;Ljava/util/Optional;)VorElse)()Lorg/apache/kafka/common/PartitionInfo;ofidreplicas!()[Lorg/apache/kafka/common/Node;inSyncReplicasofflineReplicas(Ljava/lang/String;ILorg/apache/kafka/common/Node;[Lorg/apache/kafka/common/Node;[Lorg/apache/kafka/common/Node;[Lorg/apache/kafka/common/Node;)V0org/apache/kafka/common/requests/MetadataRequest  f\ de bc ]^ [\ => Z@ RS"java/lang/invoke/LambdaMetafactory metafactoryLookup(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;%java/lang/invoke/MethodHandles$Lookupjava/lang/invoke/MethodHandles!%+^*****!* * * * * ***Y**B[I \]^ _%`*a/b4c9d?eDfOgVh]i4^^^^^!2*o !D* *ae y!r%*  * *ae B!*  %%  N/* !8 * *    !W+W*+  B*+"-*+:* !"-#=*$%YSY!SY+S&*+!'W* *(%YSY!SY+S&*  0O^chj>|  07!/*  !(*+M, *+)*+,*+ ((!"* * * *Y ` *+, ! """ "!M ** + -    !,.W*/ 0Y12* * *3W*! *! *Y ` *45:**,*!67*:*8*9*!:;W*45:<*=>**4?*@* !*AR (-27AP`io  HPij?}O*B*+C*+D  t++EF!*G+EH*IY+EJ *++* t++KF!*L+KH*IY+KJ *++*  v ,IYMNNYO:+P:+QR:STU:,#VWX-YZW[\:S^T]: *Y +^_` abc)*deYY fg aA*3W+Vbc*hYVA*3W!iY+jk+lm+nm-+opr%&')8*C+F-Q.Y/e1343KLMLNPQRSUWX Y%Z+WRL  8,,,$*,$8 " #!  a'"#$`eY+,fg:\,qrR,qs*6*t+,u:vYwx*)y'*zW+,u:vYwx6 dfg+i>jEkWlZnhpkrws~tw\ E%&+='~%&( )*+, *-Z. #/!019 **|}    !21c*~L+ *~+  34!56D **+}   (78*~+M*~*B,, 9:3 9;4<=>v2*FY**FY* $0 2?@4*+Y+*+Y+ &244(A1A** !BCQ * *-~    !/*  !D/*  !E14*  !/* !F1K* *Y ` *3W !GH;Y**  IL. MNJ*(O!PQc#*+Y*+ "##, RS%*LY+ +*! %TUVW+XYXYYZ@:*+( [\M+*i' @ ]^x,N-f-*-!R,:Y*-!:+vY,wW +,WB57 <&=,>1?6@FAKBPCXD`EfDlFoGwI>&F_&X`&xxxaUpVW oYbc\*- ,@deL*-Y-X ( f\M+* @ghB  vi ] U J1K R