4 Z [ Z Z  Z       Z  6    =  >  =    Z        ! " T# $ %&'()metadata#Lorg/apache/kafka/clients/Metadata;metadataFetchInProgressZthis$0(Lorg/apache/kafka/clients/NetworkClient;N(Lorg/apache/kafka/clients/NetworkClient;Lorg/apache/kafka/clients/Metadata;)VCodeLineNumberTableLocalVariableTablethisDefaultMetadataUpdater InnerClasses?Lorg/apache/kafka/clients/NetworkClient$DefaultMetadataUpdater; fetchNodes()Ljava/util/List; Signature2()Ljava/util/List; isUpdateDue(J)ZnowJ StackMapTable maybeUpdate(J)JtimeToNextMetadataUpdatewaitForMetadataFetchmetadataTimeoutnodeLorg/apache/kafka/common/Node;handleDisconnection(Ljava/lang/String;)VnodeIdI destinationLjava/lang/String;cluster!Lorg/apache/kafka/common/Cluster;*handleAuthenticationFailure;(Lorg/apache/kafka/common/errors/AuthenticationException;)V exception8Lorg/apache/kafka/common/errors/AuthenticationException;handleCompletedMetadataResponseg(Lorg/apache/kafka/common/requests/RequestHeader;JLorg/apache/kafka/common/requests/MetadataResponse;)Vcount requestHeader0Lorg/apache/kafka/common/requests/RequestHeader;response3Lorg/apache/kafka/common/requests/MetadataResponse;missingListenerPartitionsLjava/util/List;errorsLjava/util/Map;LocalVariableTypeTable:Ljava/util/List;LLjava/util/Map;+ requestUpdate()VcloseisAnyNodeConnecting()Z,"(JLorg/apache/kafka/common/Node;)JmetadataRequestBuilder:Lorg/apache/kafka/common/requests/MetadataRequest$Builder;nodeConnectionId-(lambda$handleCompletedMetadataResponse$2. TopicMetadata\(Lorg/apache/kafka/common/requests/MetadataResponse$TopicMetadata;)Ljava/util/stream/Stream; topicMetadataALorg/apache/kafka/common/requests/MetadataResponse$TopicMetadata; lambda$null$1/PartitionMetadata(Lorg/apache/kafka/common/requests/MetadataResponse$TopicMetadata;Lorg/apache/kafka/common/requests/MetadataResponse$PartitionMetadata;)Lorg/apache/kafka/common/TopicPartition;partitionMetadataELorg/apache/kafka/common/requests/MetadataResponse$PartitionMetadata; lambda$null$0H(Lorg/apache/kafka/common/requests/MetadataResponse$PartitionMetadata;)Z SourceFileNetworkClient.java ab c ]^ _`0 12* 3m 4v5 678 9: ;< =>;Give up sending metadata request since no node is available? @~ AB u CD EF GH Bootstrap broker {} disconnected IJ K LMN OP QRS 2 TU VWBootstrapMethodsXYZ [\] ^_` ab cdjava/util/List e fgK{} partitions have leader brokers without a matching listener, including {} hi jk lm In o+9Error while fetching metadata with correlation id {} : {}p qg rs tu8Ignoring empty metadata response with correlation id {}. vJ g lm wx, y z{org/apache/kafka/common/Node |} ~    8org/apache/kafka/common/requests/MetadataRequest$Builderjava/util/ArrayList s c  c&Sending metadata request {} to node {} @n  =Initialize connection to node {} for sending metadata request @J java/lang/Long m   [ _&org/apache/kafka/common/TopicPartition  g c  =org/apache/kafka/clients/NetworkClient$DefaultMetadataUpdaterjava/lang/Object(org/apache/kafka/clients/MetadataUpdaterorg/apache/kafka/common/Cluster java/util/Mapjava/util/Iteratorjava/lang/String?org/apache/kafka/common/requests/MetadataResponse$TopicMetadataCorg/apache/kafka/common/requests/MetadataResponse$PartitionMetadata!org/apache/kafka/clients/Metadatafetch#()Lorg/apache/kafka/common/Cluster;nodestimeToNextUpdate&org/apache/kafka/clients/NetworkClient access$000+(Lorg/apache/kafka/clients/NetworkClient;)Ijava/lang/Mathmax(JJ)JleastLoadedNode!(J)Lorg/apache/kafka/common/Node; access$100<(Lorg/apache/kafka/clients/NetworkClient;)Lorg/slf4j/Logger;org/slf4j/Loggerdebug access$200+(Lorg/apache/kafka/clients/NetworkClient;)JisBootstrapConfiguredjava/lang/IntegerparseInt(Ljava/lang/String;)InodeById!(I)Lorg/apache/kafka/common/Node;warn'(Ljava/lang/String;Ljava/lang/Object;)VupdateRequested access$300N(Lorg/apache/kafka/clients/NetworkClient;)Lorg/apache/kafka/common/utils/Time;"org/apache/kafka/common/utils/Time milliseconds()J failedUpdate<(JLorg/apache/kafka/common/errors/AuthenticationException;)V1org/apache/kafka/common/requests/MetadataResponse()Ljava/util/Collection;java/util/Collectionstream()Ljava/util/stream/Stream; &(Ljava/lang/Object;)Ljava/lang/Object; Zapply()Ljava/util/function/Function;java/util/stream/StreamflatMap8(Ljava/util/function/Function;)Ljava/util/stream/Stream;java/util/stream/CollectorstoList()Ljava/util/stream/Collector;collect0(Ljava/util/stream/Collector;)Ljava/lang/Object;isEmptysize()IvalueOf(I)Ljava/lang/Integer;min(II)IsubList(II)Ljava/util/List;9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V()Ljava/util/Map;.org/apache/kafka/common/requests/RequestHeader correlationIdunavailableTopics()Ljava/util/Set;update4(Lorg/apache/kafka/common/Cluster;Ljava/util/Set;J)Vtraceiterator()Ljava/util/Iterator;hasNextnext()Ljava/lang/Object; access$400\(Lorg/apache/kafka/clients/NetworkClient;)Lorg/apache/kafka/clients/ClusterConnectionStates;idString()Ljava/lang/String;0org/apache/kafka/clients/ClusterConnectionStates isConnecting(Ljava/lang/String;)Z access$500>(Lorg/apache/kafka/clients/NetworkClient;Ljava/lang/String;J)ZneedMetadataForAllTopics allTopics<()Lorg/apache/kafka/common/requests/MetadataRequest$Builder;0org/apache/kafka/common/requests/MetadataRequesttopics(Ljava/util/Collection;)VallowAutoTopicCreation(Ljava/util/List;Z)V access$600x(Lorg/apache/kafka/clients/NetworkClient;Lorg/apache/kafka/common/requests/MetadataRequest$Builder;Ljava/lang/String;J)V canConnect(Ljava/lang/String;J)Z access$700J(Lorg/apache/kafka/clients/NetworkClient;Lorg/apache/kafka/common/Node;J)V(Ljava/lang/Object;)Z Ztest ()Ljava/util/function/Predicate;filter9(Ljava/util/function/Predicate;)Ljava/util/stream/Stream; Zo(Lorg/apache/kafka/common/requests/MetadataResponse$PartitionMetadata;)Lorg/apache/kafka/common/TopicPartition;`(Lorg/apache/kafka/common/requests/MetadataResponse$TopicMetadata;)Ljava/util/function/Function;maptopic partition(Ljava/lang/String;I)Verror+()Lorg/apache/kafka/common/protocol/Errors;'org/apache/kafka/common/protocol/ErrorsLISTENER_NOT_FOUND)Lorg/apache/kafka/common/protocol/Errors;  "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 Z[\]^_`abcde^*+**,*fw xyzg hkab]^lme5 *f~g  hknopqeY** fghkrst@uve ]*B** 7! 7 * :  *  ** f*  &-0:?MUg>]hk]rs Tws?xs&7ys:#z{ t@$|}~e6*M,$+>,:* *f" 05g4z{6hk6.t0em$****+f#g$hk$t#e*: :!."6* #$ %&'(:)* *++$'"*, -!* .++$/* fF  -7@K]bisgR@"hkrs -i_-i_tb'e7 *0Wf g  hke6*1f g hke5*23L+4#+56M*7,89f.03gz{5hkt  %uef-8:*:^**; <:!=Y>Y*?@*AB:* C-D*E**F **7G#* H-I*-J*LfF"*@HYenu}   g>'H&hkrsz{t*%/ eU*NOPQ*RSfg  eDTY*U+VWfg eE*XYfg t@j*Zi=