4op qr s t u v w x y z { | } ~           .     .  . .    )  . .  .  . 3 |    9     .    .   H        Q P 9  R ~   ~ . g .  .    ) | . g . g 9 P H . H H  H  | . w 3  3 .   L                !"# InnerClasses$BuilderTopicAndPartitionData PartitionDataCONSUMER_REPLICA_IDI ConstantValueTOPICS ComplexArray;Lorg/apache/kafka/common/protocol/types/Field$ComplexArray;FORGOTTEN_TOPICS MAX_BYTESInt324Lorg/apache/kafka/common/protocol/types/Field$Int32;ISOLATION_LEVELInt83Lorg/apache/kafka/common/protocol/types/Field$Int8; SESSION_ID SESSION_EPOCH PARTITIONS REPLICA_ID FETCH_OFFSETInt644Lorg/apache/kafka/common/protocol/types/Field$Int64;PARTITION_MAX_BYTES MAX_WAIT_TIME MIN_BYTESLOG_START_OFFSET PARTITIONS_V0.Lorg/apache/kafka/common/protocol/types/Field; TOPICS_V0FETCH_REQUEST_V0/Lorg/apache/kafka/common/protocol/types/Schema;FETCH_REQUEST_V1FETCH_REQUEST_V2FETCH_REQUEST_V3FETCH_REQUEST_V4 PARTITIONS_V5 TOPICS_V5FETCH_REQUEST_V5FETCH_REQUEST_V6FORGOTTEN_PARTITIONSArray4Lorg/apache/kafka/common/protocol/types/Field$Array;FORGOTTEN_TOPIC_DATA_V7FETCH_REQUEST_V7FETCH_REQUEST_V8FETCH_REQUEST_PARTITION_V9FETCH_REQUEST_TOPIC_V9FETCH_REQUEST_V9FETCH_REQUEST_V10DEFAULT_RESPONSE_MAX_BYTESINVALID_LOG_START_OFFSETJ replicaIdmaxWaitminBytesmaxBytesisolationLevel1Lorg/apache/kafka/common/requests/IsolationLevel; fetchDataLjava/util/Map; SignaturevLjava/util/Map;toForgetLjava/util/List;:Ljava/util/List;metadata0Lorg/apache/kafka/common/requests/FetchMetadata;schemaVersions2()[Lorg/apache/kafka/common/protocol/types/Schema;CodeLineNumberTable(SIIIILjava/util/Map;Lorg/apache/kafka/common/requests/IsolationLevel;Ljava/util/List;Lorg/apache/kafka/common/requests/FetchMetadata;)VLocalVariableTablethis/Lorg/apache/kafka/common/requests/FetchRequest;versionSLocalVariableTypeTable(SIIIILjava/util/Map;Lorg/apache/kafka/common/requests/IsolationLevel;Ljava/util/List;Lorg/apache/kafka/common/requests/FetchMetadata;)V3(Lorg/apache/kafka/common/protocol/types/Struct;S)VpartLjava/lang/Integer;partObjLjava/lang/Object;forgottenTopic/Lorg/apache/kafka/common/protocol/types/Struct; topicNameLjava/lang/String;forgottenTopicObjpartitionResponse partitionoffsetlogStartOffsetcurrentLeaderEpochLjava/util/Optional; partitionData=Lorg/apache/kafka/common/requests/FetchRequest$PartitionData;partitionResponseObj topicResponsetopictopicResponseObjstruct)Ljava/util/Optional; StackMapTable%&getErrorResponseK(ILjava/lang/Throwable;)Lorg/apache/kafka/common/requests/AbstractResponse;>Lorg/apache/kafka/common/requests/FetchResponse$PartitionData;entryEntryLjava/util/Map$Entry;throttleTimeMseLjava/lang/Throwable;error)Lorg/apache/kafka/common/protocol/Errors; responseDataLjava/util/LinkedHashMap;nLorg/apache/kafka/common/requests/FetchResponse$PartitionData;|Ljava/util/Map$Entry;Ljava/util/LinkedHashMap;>;'(()I()Ljava/util/Map;x()Ljava/util/Map;()Ljava/util/List;<()Ljava/util/List;isFromFollower()Z3()Lorg/apache/kafka/common/requests/IsolationLevel;2()Lorg/apache/kafka/common/requests/FetchMetadata;parseG(Ljava/nio/ByteBuffer;S)Lorg/apache/kafka/common/requests/FetchRequest;bufferLjava/nio/ByteBuffer;toStruct1()Lorg/apache/kafka/common/protocol/types/Struct;fetchPartitionDatapartitionEntry topicDatapartitionArray topicEntryELorg/apache/kafka/common/requests/FetchRequest$TopicAndPartitionData; partitions(Lorg/apache/kafka/common/TopicPartition;toForgetStructtopicsToPartitionstoForgetStructs topicsData topicArraygLjava/util/Map$Entry;ALjava/util/List;Lorg/apache/kafka/common/requests/FetchRequest$TopicAndPartitionData;%Ljava/util/List;NLjava/util/Map$Entry;>;HLjava/util/Map;>;Ljava/util/List;>;)lambda$toStruct$0$(Ljava/lang/String;)Ljava/util/List;(SIIIILjava/util/Map;Lorg/apache/kafka/common/requests/IsolationLevel;Ljava/util/List;Lorg/apache/kafka/common/requests/FetchMetadata;Lorg/apache/kafka/common/requests/FetchRequest$1;)Vx0x1x2x3x4x5x6x7x8x91Lorg/apache/kafka/common/requests/FetchRequest$1;()V SourceFileFetchRequest.javajava/lang/Integer.org/apache/kafka/common/requests/FetchMetadata -org/apache/kafka/common/protocol/types/Schema * +, - ./ 07 -org/apache/kafka/common/requests/FetchRequest 12 34 .56 789 :; <java/util/ArrayList = 3> .?-org/apache/kafka/common/protocol/types/Struct@ AD .E .F&org/apache/kafka/common/TopicPartition G HI Jjava/util/LinkedHashMap l K .LM NO 1P QR ST;org/apache/kafka/common/requests/FetchRequest$PartitionData U) VW' XY Z[\ ]^( _= `ajava/util/Map$Entry(Lorg/apache/kafka/common/protocol/types/Field$ComplexArray;)ZP(Lorg/apache/kafka/common/protocol/types/Field$ComplexArray;)[Ljava/lang/Object;-org/apache/kafka/common/protocol/CommonFields TOPIC_NAMEStr2Lorg/apache/kafka/common/protocol/types/Field$Str;F(Lorg/apache/kafka/common/protocol/types/Field$Str;)Ljava/lang/String;I(Lorg/apache/kafka/common/protocol/types/Field$Array;)[Ljava/lang/Object;(Ljava/lang/String;I)Vadd(Ljava/lang/Object;)Z(II)V PARTITION_IDF(Lorg/apache/kafka/common/protocol/types/Field$Int64;)Ljava/lang/Long;java/lang/Long longValue()JG(Lorg/apache/kafka/common/protocol/types/Field$Int64;J)Ljava/lang/Long;CURRENT_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;(JJILjava/util/Optional;)Vput8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; forException@(Ljava/lang/Throwable;)Lorg/apache/kafka/common/protocol/Errors;entrySet()Ljava/util/Set; java/util/Setiterator()Ljava/util/Iterator;hasNextnext()Ljava/lang/Object;,org/apache/kafka/common/record/MemoryRecordsEMPTY.Lorg/apache/kafka/common/record/MemoryRecords;k(Lorg/apache/kafka/common/protocol/Errors;JJJLjava/util/List;Lorg/apache/kafka/common/record/BaseRecords;)VgetKey sessionIdG(Lorg/apache/kafka/common/protocol/Errors;Ljava/util/LinkedHashMap;II)V parseRequestG(SLjava/nio/ByteBuffer;)Lorg/apache/kafka/common/protocol/types/Struct;()S requestSchema2(S)Lorg/apache/kafka/common/protocol/types/Schema;2(Lorg/apache/kafka/common/protocol/types/Schema;)V batchByTopic&(Ljava/util/Iterator;)Ljava/util/List;setf(Lorg/apache/kafka/common/protocol/types/Field$Int32;I)Lorg/apache/kafka/common/protocol/types/Struct;valueOf(I)Ljava/lang/Integer; setIfExistsq(Lorg/apache/kafka/common/protocol/types/Field;Ljava/lang/Object;)Lorg/apache/kafka/common/protocol/types/Struct;id(B)Ljava/lang/Byte;epochinstancel(Lorg/apache/kafka/common/protocol/types/Field$ComplexArray;)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;getValue fetchOffsetf(Lorg/apache/kafka/common/protocol/types/Field$Int64;J)Lorg/apache/kafka/common/protocol/types/Struct;(J)Ljava/lang/Long;setLeaderEpochIfExistsz(Lorg/apache/kafka/common/protocol/types/Struct;Lorg/apache/kafka/common/protocol/types/Field$Int32;Ljava/util/Optional;)VtoArray()[Ljava/lang/Object;(Lorg/apache/kafka/common/protocol/types/Field$ComplexArray;[Ljava/lang/Object;)Lorg/apache/kafka/common/protocol/types/Struct;()Ljava/lang/String; &(Ljava/lang/Object;)Ljava/lang/Object; apply()Ljava/util/function/Function;computeIfAbsentC(Ljava/lang/Object;Ljava/util/function/Function;)Ljava/lang/Object;x(Lorg/apache/kafka/common/protocol/types/Field$Array;[Ljava/lang/Object;)Lorg/apache/kafka/common/protocol/types/Struct;'(Ljava/lang/String;Ljava/lang/String;)V withFields_([Lorg/apache/kafka/common/protocol/types/Field;)Lorg/apache/kafka/common/protocol/types/Field;2([Lorg/apache/kafka/common/protocol/types/Field;)V+org/apache/kafka/common/protocol/types/TypeINT32DocumentedType?@7 A6 BCE@7 FG:HYI:*3Y4JW I$$2BL`gs} !=DNnu   O  E V ui \OB2(np D N=   ( ` $!/  !" #!2 !:!/  !" #! !$%+ p,KN9Y::*LM:N8OP:QY-CCCST:UVWĻRY-*WX4KZ]HK&4&')pp*p+,k-.b/0 K14&'2b/3456>7/* 7/* 7/* 7/* 8/* 9:/* ;<=B *   @>/* ?/*  @AE Y*YZBCDE q.Y*[\]L*LM^M+*_W+*_W+*_W+*`aW+#*bcaW+6*W`aW+7*d`aW)YeN,f:NOg:+;h:/ijW)Ye:klM:NOP:  mH: <h:  = U_W > noW A p_W B qraW F st 5Wz<uvW-5W+;-uvW++,ӻwYx:*f:N8O3:yz{|:}`5WĻ)Ye:LM:NPOP:++h:/U~jW1m|uW5W++uvW+,$0<HWi{$2@Q^hk{     (;S]`odF Z pG) H IJKL&M(5N >')OtPq_ $MQR\ pGS ITJULV>'WOXtPT$MQYRTk  ZZ6D  ZZ6[ Z6 ZZ+\6>Z6V ]^2)Ye _ * .p `abcdefgh ij klY;Y+YY#Y6Y7Y<YY>YAYYYB<Y=SY>SYAS;Y/SYSYYSYSYSYSYYSYSYSYSYSYYSYSYSYSY#SYS <Y=SY>SYBSYAS;Y/SYSYYSYSYSYSY#SYS Y1+Y/SY1SY YSYSYSYSY#SY6SY7SYSYS <Y=SYFSY>SYBSYAS;Y/SYSY YSYSYSYSY#SY6SY7SYSYS 135*98@FATDbHpJ~KMOQUZ^fi mLv hnmnr g H  QRP( BC