Êþº¾4³ o n n n n n n  n  n n n n  n n  !  n" n# n$%& ' n( n) n* n+ n, n- ./ '0 '12 '3 '4 n5 67 '8 69 6: ': n;< n=>? 3'@A nBCD 9E FG H 68 nIJ @KL BMNOÿÿÿÿÿÿÿÿ QP DQ nRST LU KV KW XYZ Q[ X8 n\ n] n^ _ X: n` Xa Fb 60 cdef _g _h _ij _kl _m ^' Fn Fo pq Fr stuvw Completion InnerClassescluster!Lorg/apache/kafka/common/Cluster; partitioner/Lorg/apache/kafka/clients/producer/Partitioner;sentLjava/util/List; SignatureLLjava/util/List;>;uncommittedSends completionsLjava/util/Deque;NLjava/util/Deque;offsetsLjava/util/Map;ILjava/util/Map;consumerGroupOffsets£Ljava/util/List;>;>;uncommittedConsumerGroupOffsets‘Ljava/util/Map;>; keySerializer2Lorg/apache/kafka/common/serialization/Serializer;7Lorg/apache/kafka/common/serialization/Serializer;valueSerializer7Lorg/apache/kafka/common/serialization/Serializer; autoCompleteZclosedtransactionInitializedtransactionInFlighttransactionCommittedtransactionAbortedproducerFencedproducerFencedOnClose sentOffsets commitCountJ mockMetricsULjava/util/Map;¸(Lorg/apache/kafka/common/Cluster;ZLorg/apache/kafka/clients/producer/Partitioner;Lorg/apache/kafka/common/serialization/Serializer;Lorg/apache/kafka/common/serialization/Serializer;)VCodeLineNumberTableLocalVariableTablethis0Lorg/apache/kafka/clients/producer/MockProducer;LocalVariableTypeTable8Lorg/apache/kafka/clients/producer/MockProducer;Â(Lorg/apache/kafka/common/Cluster;ZLorg/apache/kafka/clients/producer/Partitioner;Lorg/apache/kafka/common/serialization/Serializer;Lorg/apache/kafka/common/serialization/Serializer;)Vh(ZLorg/apache/kafka/common/serialization/Serializer;Lorg/apache/kafka/common/serialization/Serializer;)Vr(ZLorg/apache/kafka/common/serialization/Serializer;Lorg/apache/kafka/common/serialization/Serializer;)V—(ZLorg/apache/kafka/clients/producer/Partitioner;Lorg/apache/kafka/common/serialization/Serializer;Lorg/apache/kafka/common/serialization/Serializer;)V¡(ZLorg/apache/kafka/clients/producer/Partitioner;Lorg/apache/kafka/common/serialization/Serializer;Lorg/apache/kafka/common/serialization/Serializer;)V()VinitTransactions StackMapTablebeginTransaction ExceptionssendOffsetsToTransaction$(Ljava/util/Map;Ljava/lang/String;)VconsumerGroupIdLjava/lang/String;uncommittedOffsetsnLjava/util/Map;2ƒ(Ljava/util/Map;Ljava/lang/String;)VcommitTransactionabortTransactionverifyProducerStateverifyTransactionsInitializedverifyNoTransactionInFlightsendQ(Lorg/apache/kafka/clients/producer/ProducerRecord;)Ljava/util/concurrent/Future;record2Lorg/apache/kafka/clients/producer/ProducerRecord;:Lorg/apache/kafka/clients/producer/ProducerRecord;(Lorg/apache/kafka/clients/producer/ProducerRecord;)Ljava/util/concurrent/Future;}(Lorg/apache/kafka/clients/producer/ProducerRecord;Lorg/apache/kafka/clients/producer/Callback;)Ljava/util/concurrent/Future;callback,Lorg/apache/kafka/clients/producer/Callback; partitionItopicPartition(Lorg/apache/kafka/common/TopicPartition;resultBLorg/apache/kafka/clients/producer/internals/ProduceRequestResult;futureBLorg/apache/kafka/clients/producer/internals/FutureRecordMetadata;offset completion;Lorg/apache/kafka/clients/producer/MockProducer$Completion;uxyJLNS¹(Lorg/apache/kafka/clients/producer/ProducerRecord;Lorg/apache/kafka/clients/producer/Callback;)Ljava/util/concurrent/Future; nextOffset+(Lorg/apache/kafka/common/TopicPartition;)JnextLjava/lang/Long;tpZflush partitionsFor$(Ljava/lang/String;)Ljava/util/List;topicM(Ljava/lang/String;)Ljava/util/List;metrics()Ljava/util/Map;W()Ljava/util/Map;setMockMetricsG(Lorg/apache/kafka/common/MetricName;Lorg/apache/kafka/common/Metric;)Vname$Lorg/apache/kafka/common/MetricName;metric Lorg/apache/kafka/common/Metric;close#(JLjava/util/concurrent/TimeUnit;)VtimeouttimeUnitLjava/util/concurrent/TimeUnit;()Z fenceProducerfenceProducerOnCloseflushed()Jhistory()Ljava/util/List;N()Ljava/util/List;>;consumerGroupOffsetsHistory¥()Ljava/util/List;>;>;clear completeNext errorNext(Ljava/lang/RuntimeException;)ZeLjava/lang/RuntimeException;V(Lorg/apache/kafka/clients/producer/ProducerRecord;Lorg/apache/kafka/common/Cluster;)I partitions numPartitionsLjava/lang/Integer;keyBytes[B valueBytes9Ljava/util/List;z{|}^(Lorg/apache/kafka/clients/producer/ProducerRecord;Lorg/apache/kafka/common/Cluster;)IpLjava/lang/Object;Lorg/apache/kafka/clients/producer/Producer; SourceFileMockProducer.java ™§ •– st ‹Œ uv †‡ ‰‡java/util/HashMap €java/util/ArrayList wx {x ‚x „€java/util/ArrayDeque |} —€z ~>org/apache/kafka/clients/producer/internals/DefaultPartitioner ™š ¶§ ŽŒjava/lang/IllegalStateException;MockProducer has already been initialized for transactions. ™€ ·§ Œ Œ ‘Œ ”Œ ¸§ ‚ƒ „… †ƒ java/util/Map ‡ˆ ‰Š Û§} ‹Œ î Ž ø§ ŒMockProducer is already closed. ’Œ6org/apache/kafka/common/errors/ProducerFencedExceptionMockProducer is fenced.6MockProducer hasn't been initialized for transactions.There is no open transaction. ¹¿&org/apache/kafka/common/KafkaExceptionFenced ™x Þ‘ ’Ý Âþ&org/apache/kafka/common/TopicPartition ™“@org/apache/kafka/clients/producer/internals/ProduceRequestResult ™”@org/apache/kafka/clients/producer/internals/FutureRecordMetadata*org/apache/kafka/common/record/RecordBatch •– ™— ÕÖ9org/apache/kafka/clients/producer/MockProducer$Completion0org/apache/kafka/clients/producer/RecordMetadata ™˜ ™™ š›œ žjava/lang/Long Ÿò ùî éê “Œ ™  úû ¡¢ £{ ¤…"java/lang/IllegalArgumentExceptionjava/lang/StringBuilder%Invalid partition given with record: ¥¦ ¥§ is not in the range [0... ¥¨]. ©‘ ª« ¬¢­ ®¯ °¢± ².org/apache/kafka/clients/producer/MockProducerjava/lang/Object*org/apache/kafka/clients/producer/Producer0org/apache/kafka/clients/producer/ProducerRecord*org/apache/kafka/clients/producer/Callbackorg/apache/kafka/common/Clusterjava/lang/Integerjava/lang/Stringjava/util/Listempty#()Lorg/apache/kafka/common/Cluster;(Ljava/lang/String;)Vjava/util/ObjectsrequireNonNull&(Ljava/lang/Object;)Ljava/lang/Object;size()Igetput8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;putAll(Ljava/util/Map;)VaddAll(Ljava/util/Collection;)ZisEmptyadd(Ljava/lang/Object;)Z*(Ljava/lang/String;Ljava/lang/Throwable;)V()Ljava/lang/String;partitionsForTopic(Ljava/lang/String;I)V+(Lorg/apache/kafka/common/TopicPartition;)VvalueOf(J)Ljava/lang/Long;Y(Lorg/apache/kafka/clients/producer/internals/ProduceRequestResult;JJLjava/lang/Long;II)V@(Lorg/apache/kafka/common/TopicPartition;JJJLjava/lang/Long;II)V¤(JLorg/apache/kafka/clients/producer/RecordMetadata;Lorg/apache/kafka/clients/producer/internals/ProduceRequestResult;Lorg/apache/kafka/clients/producer/Callback;)Vcomplete(Ljava/lang/RuntimeException;)Vjava/util/DequeaddLast(Ljava/lang/Object;)V longValue(Ljava/util/Collection;)V pollFirst()Ljava/lang/Object;()Ljava/lang/Integer;intValueappend-(Ljava/lang/String;)Ljava/lang/StringBuilder;-(Ljava/lang/Object;)Ljava/lang/StringBuilder;(I)Ljava/lang/StringBuilder;toStringheaders*()Lorg/apache/kafka/common/header/Headers;key0org/apache/kafka/common/serialization/Serializer serializeP(Ljava/lang/String;Lorg/apache/kafka/common/header/Headers;Ljava/lang/Object;)[Bvalue-org/apache/kafka/clients/producer/Partitioner^(Ljava/lang/String;Ljava/lang/Object;[BLjava/lang/Object;[BLorg/apache/kafka/common/Cluster;)I!nopstuvwxyz{xyz|}y~€y‚xyƒ„€y…†‡yˆ‰‡yŠ‹ŒŒŽŒŒŒ‘Œ’Œ“Œ”Œ•–—€y˜%™š›,r*·* µ*+µ*µ*-µ*µ*µ*»Y· µ *» Y· µ *» Y· µ*» Y· µ*»Y· µ*»Y·µ*»Y· µ±œ>YF Z[\]^$_/`:aEbPc[dfeqf>ržŸrstr‹Œruvr†‡r‰‡  rž¡r†ˆr‰Šy¢™£›„*¸»Y·,-·±œ pq*žŸ‹Œ†‡‰‡  ž¡†ˆ‰Šy¤™¥›‰ *¸,-·±œ | }4 žŸ ‹Œ uv †‡ ‰‡   ž¡ †ˆ ‰Šy¦™§›L *¸·±œ … †  žŸ   ž¡¨§›p*·*´™ »Y·¿*µ±œŠ‹ ŒŽ žŸ  ž¡©ª§›q*·*·*µ*µ *µ!*µ"±œ“”• –—˜™ žŸ  ž¡«3¬­›ûN*·*·*·#,¸$W+¹%š±*´,¹&À'N-Ç»Y· N*´,-¹(W-+¹)*µ"±œ6 žŸ  ¡¢£¥)¦-§5¨AªH«M¬*NžŸN€N®¯)%°€  Nž¡N±)%°±© ü%²«3y³´§›ßf*·*·*·#*¶**´ *´¹+W*´¹,š*´*´¹-W*´¹.*»Y· µ*µ *µ!*µ*Y´ aµ±œ:°±² ´¶·*¸8ºA»L¼Q½V¾[ÀeÁ fžŸ  fž¡©8«3µ§›’2*·*·*·#*¶**´¹.*´¹/*µ *µ!*µ±œ* ÅÆÇ ÈÉÊ"Ë'Ì,Í1Î 2žŸ  2ž¡«3"¶§›y#*´0™ »Y1·¿*´2™ »3Y4·5¿±œÑÒÔÕ"× #žŸ  #ž¡©·§›_*´š »Y6·¿±œÚÛÝ žŸ  ž¡©¸§›_*´š »Y7·¿±œàáã žŸ  ž¡©!¹º›W*+¶8°œìžŸ»¼ ž¡»½y¾!¹¿›ò á*´0™ »Y1·¿*´2™»9Y4»3Y:·5·;¿>*´+¶<¶=¹>š *+*´·?>»@Y+¶<·A:»BY·C:»DY F ¸H·I:*·J7»KY»LY F ¸H·M,·N: *´š*´ +¹-W§*´+¹-W*´™  ¶O§*´ ¹P°œRö÷ùú+ü-ý@þJÿXcx€“£ª¸ Ã Ê ÓÞ\ សỼáÀÁ-´ÂÃX‰ÄÅc~ÆÇxiÈÉ€aÊ–£>ËÌ  ឡỽ©)üÿm ÍÎÏÐÑÒÓ  yÔÕÖ›¾>*´ +¹&ÀQM,Ç*´ + ¸H¹(W ­,¶R a¸HN*´ +-¹(W,¶R­œ!#-9*-×Ø>žŸ>ÙÅ0ÊØ  >ž¡©ü#Ú!Û§›k*·*´¹Sš *¶TW§ÿﱜ#$%& žŸ  ž¡©ÜÝ›O *´+¶=°œ) žŸ Þ¯   ž¡yßàá›A*´°œ- žŸ  ž¡yâãä›a *´+,¹(W±œ 4 5  žŸ åæ çè   ž¡é§›G* ¶U±œ 9: žŸ  ž¡éê›|*´V™ »3Y4·5¿*µ0±œ>?AB žŸë–ìí  ž¡©î›A*´0¬œE žŸ  ž¡!率V*·*·*µ2±œIJK L žŸ  ž¡ð§›V*·*·*µV±œOPQ R žŸ  ž¡Žî›A*´¬œU žŸ  ž¡î›A*´¬œY žŸ  ž¡î›A*´ ¬œ] žŸ  ž¡‘î›A*´!¬œa žŸ  ž¡ñî›F *´¹S¬œe  žŸ   ž¡”î›A*´"¬œi žŸ  ž¡•ò›A*´­œm žŸ  ž¡!óô›H » Y*´ ·W°œt  žŸ   ž¡yõ!öô›H » Y*´·W°œ{  žŸ   ž¡y÷!ø§›«G*´ ¹.*´¹.*´¹X*´¹.*´¹/*µ*µ*µ *µ!*µ2±œ. ‚ ƒ„…$†-‡2ˆ7‰<ŠA‹FŒ GžŸ  Gž¡!ùî›B*¶Y¬œ” žŸ  ž¡!úû›ˆ*´¹ZÀKM,Æ ,+¶O¬¬œ žŸ ¢ žŸüý ËÌ  ž¡©üÓÂþ›¢+¶[N+¶<:-ÆS,¶=:¹\6-¶]› -¶]¡-»^Y»_Y·`a¶b-¶cd¶b¶ef¶b¶g·h¿-¶]¬*´+¶i+¶j¹k:*´+¶i+¶l¹k:*´+¶j+¶l,¹m¬œ. ª« ¬­® °0±Zµ_·t¸‰¹\ Hÿx ?➟¢»¼¢st —Þ¯t.‰  Hÿ¢ž¡¢»½© ÿ0ÍÎ )ùy y   r Knq