4xy z { | } ~       I                        1 1  1 1 0  ;   ?  B D             Z Z  Z W Y   ^ `     B       Z             } ;   }  }       B  B B   ? ?  B  B        ! "#$%&'( ) * + , - . / 0123  PartitionData InnerClassesAbortedTransactionRESPONSES_KEY_NAMELjava/lang/String; ConstantValuePARTITIONS_KEY_NAMEHIGH_WATERMARKInt644Lorg/apache/kafka/common/protocol/types/Field$Int64;LOG_START_OFFSETPARTITION_HEADER_KEY_NAMEABORTED_TRANSACTIONS_KEY_NAMERECORD_SET_KEY_NAME"FETCH_RESPONSE_PARTITION_HEADER_V0/Lorg/apache/kafka/common/protocol/types/Schema;FETCH_RESPONSE_PARTITION_V0FETCH_RESPONSE_TOPIC_V0FETCH_RESPONSE_V0FETCH_RESPONSE_V1FETCH_RESPONSE_V2FETCH_RESPONSE_V3LAST_STABLE_OFFSET PRODUCER_ID FIRST_OFFSET%FETCH_RESPONSE_ABORTED_TRANSACTION_V4"FETCH_RESPONSE_PARTITION_HEADER_V4"FETCH_RESPONSE_PARTITION_HEADER_V5FETCH_RESPONSE_PARTITION_V4FETCH_RESPONSE_PARTITION_V5FETCH_RESPONSE_TOPIC_V4FETCH_RESPONSE_TOPIC_V5FETCH_RESPONSE_V4FETCH_RESPONSE_V5FETCH_RESPONSE_V6 SESSION_IDInt324Lorg/apache/kafka/common/protocol/types/Field$Int32;FETCH_RESPONSE_V7FETCH_RESPONSE_V8FETCH_RESPONSE_V9FETCH_RESPONSE_V10INVALID_HIGHWATERMARKJINVALID_LAST_STABLE_OFFSETINVALID_LOG_START_OFFSETthrottleTimeMsIerror)Lorg/apache/kafka/common/protocol/Errors; sessionId responseDataLjava/util/LinkedHashMap; SignatureLjava/util/LinkedHashMap;>;schemaVersions2()[Lorg/apache/kafka/common/protocol/types/Schema;CodeLineNumberTableG(Lorg/apache/kafka/common/protocol/Errors;Ljava/util/LinkedHashMap;II)VLocalVariableTablethis0Lorg/apache/kafka/common/requests/FetchResponse;LocalVariableTypeTable5Lorg/apache/kafka/common/requests/FetchResponse;(Lorg/apache/kafka/common/protocol/Errors;Ljava/util/LinkedHashMap;>;II)Vparsea(Lorg/apache/kafka/common/protocol/types/Struct;)Lorg/apache/kafka/common/requests/FetchResponse;abortedTransactionStruct/Lorg/apache/kafka/common/protocol/types/Struct; producerId firstOffsetabortedTransactionObjLjava/lang/Object;abortedTransactionsArray[Ljava/lang/Object;partitionResponsepartitionResponseHeader partition highWatermarklastStableOffsetlogStartOffset baseRecords,Lorg/apache/kafka/common/record/BaseRecords;records.Lorg/apache/kafka/common/record/MemoryRecords;abortedTransactionsLjava/util/List; partitionData>Lorg/apache/kafka/common/requests/FetchResponse$PartitionData;partitionResponseObj topicResponsetopictopicResponseObjstructULjava/util/List;nLorg/apache/kafka/common/requests/FetchResponse$PartitionData;Ljava/util/LinkedHashMap;>; StackMapTable45678(Lorg/apache/kafka/common/protocol/types/Struct;)Lorg/apache/kafka/common/requests/FetchResponse;toStruct2(S)Lorg/apache/kafka/common/protocol/types/Struct;versionStoSendl(Ljava/lang/String;Lorg/apache/kafka/common/requests/ResponseHeader;S)Lorg/apache/kafka/common/network/Send;destresponseHeader1Lorg/apache/kafka/common/requests/ResponseHeader; apiVersionresponseHeaderStructresponseBodyStructbufferLjava/nio/ByteBuffer;sendsLjava/util/Queue;9Ljava/util/Queue;+()Lorg/apache/kafka/common/protocol/Errors;()Ljava/util/LinkedHashMap;()Ljava/util/LinkedHashMap;>;()I errorCounts()Ljava/util/Map;responseLjava/util/Map;MLjava/util/Map;9:O()Ljava/util/Map;H(Ljava/nio/ByteBuffer;S)Lorg/apache/kafka/common/requests/FetchResponse;x(Ljava/nio/ByteBuffer;S)Lorg/apache/kafka/common/requests/FetchResponse;addResponseDataV(Lorg/apache/kafka/common/protocol/types/Struct;ILjava/lang/String;Ljava/util/Queue;)V topicData allTopicData~(Lorg/apache/kafka/common/protocol/types/Struct;ILjava/lang/String;Ljava/util/Queue;)V addTopicDataU(Ljava/lang/String;Ljava/util/Queue;Lorg/apache/kafka/common/protocol/types/Struct;)VallPartitionData;}(Ljava/lang/String;Ljava/util/Queue;Lorg/apache/kafka/common/protocol/types/Struct;)VaddPartitionDataheaderq(SILorg/apache/kafka/common/protocol/Errors;Ljava/util/Iterator;I)Lorg/apache/kafka/common/protocol/types/Struct;abortedTransactionCLorg/apache/kafka/common/requests/FetchResponse$AbortedTransaction;abortedTransactionStructsfetchPartitionData errorCodepartitionDataHeaderpartitionEntryEntryLjava/util/Map$Entry;partitionArray topicEntryTopicAndPartitionDataELorg/apache/kafka/common/requests/FetchRequest$TopicAndPartitionData; partIteratorLjava/util/Iterator; topicsData topicArrayALjava/util/List;CLorg/apache/kafka/common/requests/FetchResponse$PartitionData;mLjava/util/Map$Entry;>;Lorg/apache/kafka/common/requests/FetchRequest$TopicAndPartitionData;>;Ljava/util/Iterator;>;>;Ljava/util/List;>;>;&(SILorg/apache/kafka/common/protocol/Errors;Ljava/util/Iterator;>;>;I)Lorg/apache/kafka/common/protocol/types/Struct;sizeOf(SLjava/util/Iterator;)I(SLjava/util/Iterator;>;>;)IshouldClientThrottle(S)Z()VdLorg/apache/kafka/common/requests/AbstractResponse; SourceFileFetchResponse.java.org/apache/kafka/common/requests/FetchMetadata-org/apache/kafka/common/protocol/types/Schema t java/util/LinkedHashMap.org/apache/kafka/common/requests/FetchResponse responses <=-org/apache/kafka/common/protocol/types/Struct> ?B CDpartition_responsespartition_header EF G CH I: JM CNO PQ6 RS CTU VW XY  record_set Z[,org/apache/kafka/common/record/MemoryRecordsjava/lang/IllegalStateExceptionjava/lang/StringBuilderUnknown records type found: \]4 ^_ \` ab caborted_transactions dejava/util/ArrayList f Aorg/apache/kafka/common/requests/FetchResponse$AbortedTransaction g8 hi6x,2::::6 6   C 2:  :  :   6 !"#$: %&'7 ()+'7 ,)+'7 -.:/"0Y1Y2345678/:: 9:q 9:c;Y<::66D2::=&'7>&'7!?Y!@AWBYC:+DYEFW Y*!G#$+*HJ *KJ L"?@!A(B2CQDXEaFnG~HIJLMNOQRSTU V#W*X7YDZWV]_raC@ded*-7 D!#4eX, a# n~     rQ3 (b2X!i r-   !"9 !"#$G !"#$,%&'c***MN*Oj() *+ p,P:*Q:R`S:RR`TWUVWWYX:YY+ZYS[\W*+]^Y+_* op st*u1v7x@yYze{Rpp,p-.p/)j0 c1W23@045p@0467A*  8A*  9:A*  :A*  ;<6`YaL*bcM,d,eBN*+-fg+(4 ( =6.;>6.;?@AB CChi*jk23()D EF  *:*!l[S:TW*!"#mW*K TWTWVW-YY,ZYS[\Wr*Hl;S:TWTWVW-YY,ZYS[\W0S:TWVW-YY,ZYS[\W:662:,-nb 0@IOgt{\ N23{.23'23 G,45H 46jA, I JKB y,N,:o-p`S:o-qTWVW+YY*ZYS[\W:662: *+ r. '06NhrxHh  y,y45yGqiL[23 y46#Z  M NO PK[,N,-.:-R`S:-UsTWVW+YY*ZYS[\W+*t\W&  -3KZ>[,[45[TQL  A23 [46O &R#Yhiu:HvwW!,xywWKvwW-z:;Y{:|:de}: ~:   W;Y{:  MN:  dV e:  B:fx6x x6 ~:~:  W!W%W(l(W9Wy;Y<:|:dAe?:9~:=W>WAW9W,wWW-W AW  W AWEW+-;<AJir(6>J]    &/ST]cU8V.W) XDY[ rG \ i]_ #()###`a#AbJcR]cUd8VeDYf \d i]g #`hAbiJcd S !A$$AD !A$$Aj$ACklm$AG4 !A$$Aj$!A$$m noV+OR`()`a `hpqr]  ()   @st Y%Y,YYSY!SY%SYYYSYY-SYYSYYYSYYYYSYYHSYYYSY(Y=Y>YY=SY>SYYSY!SY%SY(SYY9SYYSY!SY%SY(SY,SYY9SYYYSYY-SYYYSYY-SYYSYYYSYYSYYYSYYHSYYYSYYHSYYYS YKYYHSY!SYKSYYYS vLNU<Yh]aejmruwz0~[h)S}uvwJ B? Z }^@A KL