7+com/dexels/kafka/impl/KafkaTopicPublisher$2-io/reactivex/subscribers/DisposableSubscriber logCounterLjava/util/Map; SignatureKLjava/util/Map; failCounterthis$0+Lcom/dexels/kafka/impl/KafkaTopicPublisher;val$maxInFlightIval$defaultTopicLjava/util/Optional;C(Lcom/dexels/kafka/impl/KafkaTopicPublisher;ILjava/util/Optional;)VCode      ()Vjava/util/HashMap    " LineNumberTableLocalVariableTablethis-Lcom/dexels/kafka/impl/KafkaTopicPublisher$2;onStart )+*)com/dexels/kafka/impl/KafkaTopicPublisher ,-loggerLorg/slf4j/Logger;/Initial maxinflight: {} items. 132java/lang/Integer 45valueOf(I)Ljava/lang/Integer; 798org/slf4j/Logger :;info'(Ljava/lang/String;Ljava/lang/Object;)V = >?request(J)V onCompleteBKafka producer done. 7D EFwarn(Ljava/lang/String;)V H IdisposeonError(Ljava/lang/Throwable;)VMError: 7O PQerror*(Ljava/lang/String;Ljava/lang/Throwable;)VeLjava/lang/Throwable;onNext,(Lcom/dexels/pubsub/rx2/api/PubSubMessage;)V WYX'com/dexels/pubsub/rx2/api/PubSubMessage Z[topic()Ljava/util/Optional; ]_^java/util/Optional `a isPresent()ZcMissing topic found....e DUMPERROR ]g hiorElse&(Ljava/lang/Object;)Ljava/lang/Object;kjava/lang/String m nolog>(Ljava/lang/String;Lcom/dexels/pubsub/rx2/api/PubSubMessage;)V Wq rskey()Ljava/lang/String; Wu vwvalue()[By z{acceptu(Lcom/dexels/kafka/impl/KafkaTopicPublisher$2;Lcom/dexels/pubsub/rx2/api/PubSubMessage;)Ljava/util/function/Consumer;} z~(Lcom/dexels/kafka/impl/KafkaTopicPublisher$2;Lcom/dexels/pubsub/rx2/api/PubSubMessage;Ljava/lang/String;)Ljava/util/function/Consumer; ) publishc(Ljava/lang/String;Ljava/lang/String;[BLjava/util/function/Consumer;Ljava/util/function/Consumer;)Vmsg)Lcom/dexels/pubsub/rx2/api/PubSubMessage;Ljava/lang/String; StackMapTable apply()Ljava/util/function/Function;  java/util/Map computeIfAbsentC(Ljava/lang/Object;Ljava/util/function/Function;)Ljava/lang/Object;&java/util/concurrent/atomic/AtomicLong incrementAndGet()J#Published: {} messages to topic: {} java/lang/Long 4(J)Ljava/lang/Long; 7 :9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)Vcount(Ljava/util/concurrent/atomic/AtomicLong;cJ logProblemS(Lcom/dexels/pubsub/rx2/api/PubSubMessage;Ljava/lang/String;Ljava/lang/Throwable;)V j ([B)VHFailed publishing message to topic: {} fail count: {} key: {} value: {}java/lang/Object 7 P((Ljava/lang/String;[Ljava/lang/Object;)VPublish failuretmessage(Ljava/lang/Object;)V  TUlambda$0>(Lcom/dexels/pubsub/rx2/api/PubSubMessage;Ljava/lang/Object;)V W commitoLjava/lang/Object;lambda$1Error detected enqueuing:  lambda$2<(Ljava/lang/String;)Ljava/util/concurrent/atomic/AtomicLong; ?tpclambda$3 SourceFileKafkaTopicPublisher.javaZLio/reactivex/subscribers/DisposableSubscriber;EnclosingMethod backpressurePublisher7(Ljava/util/Optional;I)Lorg/reactivestreams/Subscriber;BootstrapMethods "java/lang/invoke/LambdaMetafactory  metafactory(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;    Ki  i   InnerClasses%java/lang/invoke/MethodHandles$Lookupjava/lang/invoke/MethodHandlesLookupNestHost     `**+**-**Y*Y!#!")$ *%&'M(.*06**<#&'($ %&@A(AC*G#, -.$ %&JKD (L+N# 2 3$ %& RSTUc+V\*\ (bC+V*dfjfjM*,+l*,+p+t*+x*+,|#* 78 :&;8:9<?>WA_>bF$ c%&c9*Z no5*+N-7q (+#IJK$L4N$45%&5Z5" 4 b*!,:7jY+t:+p:(Y,SYSYSYS(-N#QRS*T2UVVaW$Rb%&bbZbSNG*820rAT) *+W#$H +* <#?@ A$ %& X(-N* <*+,-ű#B CDE$%&RS 3 Y ɰ#I$   3 Y ɰ#Q$  )*)