7X'com/dexels/mongodb/sink/MongodbSinkTask&org/apache/kafka/connect/sink/SinkTaskbulkSizeLjava/lang/Integer; generationLjava/lang/String; instanceNamesinkNametenantLjava/util/Optional; Signature(Ljava/util/Optional; deployment updateCount(Ljava/util/concurrent/atomic/AtomicLong;loggerLorg/slf4j/Logger;mappingLjava/util/Map;\Ljava/util/Map;>; mongoClient Lcom/mongodb/client/MongoClient;()VCode&java/util/concurrent/atomic/AtomicLong   "  $&%org/slf4j/LoggerFactory '( getLogger%(Ljava/lang/Class;)Lorg/slf4j/Logger; * LineNumberTableLocalVariableTable this)Lcom/dexels/mongodb/sink/MongodbSinkTask;version()Ljava/lang/String;3,com/dexels/mongodb/sink/MongodbSinkConnector 2 26 01start(Ljava/util/Map;)V8(Ljava/util/Map;)V; bulk.size =?> java/util/Map @Aget&(Ljava/lang/Object;)Ljava/lang/Object;Cjava/lang/String EGFjava/lang/Integer HIparseInt(Ljava/lang/String;)I EK LMvalueOf(I)Ljava/lang/Integer; O Q0org/apache/kafka/connect/errors/ConnectExceptionS&Setting bulk.size should be an integer PU V(Ljava/lang/String;)VXSink task settings: {} Z\[org/slf4j/Logger ]^info'(Ljava/lang/String;Ljava/lang/Object;)V`mongodb.databasebconnectionStringdmongodb.collectionsftopics i  l  o  rtsjava/util/Optional uv ofNullable((Ljava/lang/Object;)Ljava/util/Optional; x  { }, B split'(Ljava/lang/String;)[Ljava/lang/String; java/util/Arrays asList%([Ljava/lang/Object;)Ljava/util/List;   createClient4(Ljava/lang/String;)Lcom/mongodb/client/MongoClient;   com/mongodb/client/MongoClient  getDatabase6(Ljava/lang/String;)Lcom/mongodb/client/MongoDatabase;java/util/HashMap    java/util/List @(I)Ljava/lang/Object;  com/mongodb/client/MongoDatabase  getCollection8(Ljava/lang/String;)Lcom/mongodb/client/MongoCollection; = put8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; size()Ijava/lang/ExceptionmapeLjava/lang/Exception;database collectionscollectionsListLjava/util/List; topicsListdb"Lcom/mongodb/client/MongoDatabase;iItopic collectionLocalVariableTypeTable5Ljava/util/Map;$Ljava/util/List; StackMapTable+org/bson/codecs/configuration/CodecRegistry+org/bson/codecs/configuration/CodecProvider@com/dexels/mongodb/sink/customcodecs/CoordinateTypeCodecProvider (Z)V -org/bson/codecs/configuration/CodecRegistries  fromProviders]([Lorg/bson/codecs/configuration/CodecProvider;)Lorg/bson/codecs/configuration/CodecRegistry; com/mongodb/MongoClientSettings getDefaultCodecRegistry/()Lorg/bson/codecs/configuration/CodecRegistry; fromRegistries]([Lorg/bson/codecs/configuration/CodecRegistry;)Lorg/bson/codecs/configuration/CodecRegistry; builder+()Lcom/mongodb/MongoClientSettings$Builder;com/mongodb/ConnectionString U 'com/mongodb/MongoClientSettings$Builder applyConnectionStringI(Lcom/mongodb/ConnectionString;)Lcom/mongodb/MongoClientSettings$Builder;  codecRegistryX(Lorg/bson/codecs/configuration/CodecRegistry;)Lcom/mongodb/MongoClientSettings$Builder; build#()Lcom/mongodb/MongoClientSettings; com/mongodb/client/MongoClients createC(Lcom/mongodb/MongoClientSettings;)Lcom/mongodb/client/MongoClient;-Lorg/bson/codecs/configuration/CodecRegistry;settings!Lcom/mongodb/MongoClientSettings;transformerForTopic((Ljava/lang/String;)Ljava/util/Optional;e(Ljava/lang/String;)Ljava/util/Optional;,com/dexels/kafka/streams/api/TopologyContext M(Ljava/util/Optional;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V /com/dexels/mongodb/sink/SinkTransformerRegistry transformerForSinkh(Ljava/lang/String;Lcom/dexels/kafka/streams/api/TopologyContext;Ljava/lang/String;)Ljava/util/Optional;writeModelFromRecordb(Lorg/apache/kafka/connect/sink/SinkRecord;)Lcom/dexels/mongodb/sink/MongodbSinkTask$TopicElement;   (org/apache/kafka/connect/sink/SinkRecord   value()Ljava/lang/Object;-com/dexels/replication/api/ReplicationMessage   key  1    operation;()Lcom/dexels/replication/api/ReplicationMessage$Operation; 7com/dexels/replication/api/ReplicationMessage$Operation DELETE9Lcom/dexels/replication/api/ReplicationMessage$Operation;   !equals(Ljava/lang/Object;)Z#4com/dexels/mongodb/sink/MongodbSinkTask$TopicElement%'com/mongodb/client/model/DeleteOneModel'_id )+* com/mongodb/client/model/Filters ,-eqA(Ljava/lang/String;Ljava/lang/Object;)Lorg/bson/conversions/Bson; $/ 0(Lorg/bson/conversions/Bson;)V "2 3u(Lcom/dexels/mongodb/sink/MongodbSinkTask;Ljava/lang/String;Ljava/lang/String;Lcom/mongodb/client/model/WriteModel;)V 5 r7 89 isPresent()Z r; @ =9com/dexels/replication/transformer/api/MessageTransformer ?A@*com/dexels/kafka/streams/api/CoreOperators BC"transformerParametersFromTopicName#(Ljava/lang/String;)Ljava/util/Map; <E FGapplyo(Ljava/util/Map;Lcom/dexels/replication/api/ReplicationMessage;)Lcom/dexels/replication/api/ReplicationMessage; IKJjava/util/Collections LMemptySet()Ljava/util/Set;  O PQvalueMap!(ZLjava/util/Set;)Ljava/util/Map;Sorg/bson/Document RU 8 RW XYappend9(Ljava/lang/String;Ljava/lang/Object;)Lorg/bson/Document;[ replicated]java/util/Date \`(com/mongodb/client/model/ReplaceOneModelb'com/mongodb/client/model/ReplaceOptions a ae fgupsert,(Z)Lcom/mongodb/client/model/ReplaceOptions; _i jY(Lorg/bson/conversions/Bson;Ljava/lang/Object;Lcom/mongodb/client/model/ReplaceOptions;)Vrecord*Lorg/apache/kafka/connect/sink/SinkRecord;message/Lcom/dexels/replication/api/ReplicationMessage;transjsonMap newDocumentLorg/bson/Document;QLjava/util/Optional;5Ljava/util/Map;(Ljava/util/Collection;)VE(Ljava/util/Collection;)Vxjava/util/ArrayList wz u | }~stream()Ljava/util/stream/Stream; FH(Lcom/dexels/mongodb/sink/MongodbSinkTask;)Ljava/util/function/Function; java/util/stream/Stream 8(Ljava/util/function/Function;)Ljava/util/stream/Stream; accept.(Ljava/util/Map;)Ljava/util/function/Consumer;  forEach (Ljava/util/function/Consumer;)V)com/mongodb/client/model/BulkWriteOptions   ordered.(Z)Lcom/mongodb/client/model/BulkWriteOptions; = MkeySet  java/util/Set iterator()Ljava/util/Iterator; java/util/Iterator  next"com/mongodb/client/MongoCollection   getNamespace()Lcom/mongodb/MongoNamespace; com/mongodb/MongoNamespace 1toString =  logOccasionally(Ljava/lang/String;I)V = MentrySet | F()Ljava/util/function/Function; java/util/stream/Collectors toList()Ljava/util/stream/Collector;  collect0(Ljava/util/stream/Collector;)Ljava/lang/Object;   bulkWrite_(Ljava/util/List;Lcom/mongodb/client/model/BulkWriteOptions;)Lcom/mongodb/bulk/BulkWriteResult;MongoBulkWriteException: Z error*(Ljava/lang/String;Ljava/lang/Throwable;)V #com/mongodb/MongoBulkWriteException getWriteErrors()Ljava/util/List; com/mongodb/bulk/BulkWriteError;;Ljava/util/Map;>;>;]Ljava/util/Map;>;LLjava/util/List;>;java/util/Collection   incrementAndGet()Jd !About to write {} documents to {} Z ]9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)VcountJflushq(Ljava/util/Map;)VnLjava/util/Map;stop  closelambda$1H(Ljava/util/Map;Lcom/dexels/mongodb/sink/MongodbSinkTask$TopicElement;)V "  "  "! "#model%Lcom/mongodb/client/model/WriteModel;element6Lcom/dexels/mongodb/sink/MongodbSinkTask$TopicElement;llambda$2<(Ljava/util/Map$Entry;)Lcom/mongodb/client/model/WriteModel; *,+java/util/Map$Entry - getValue/#com/mongodb/client/model/WriteModelLjava/util/Map$Entry;cLjava/util/Map$Entry;>; SourceFileMongodbSinkTask.javaBootstrapMethods 687"java/lang/invoke/LambdaMetafactory 9: 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;5A > =(Ljava/lang/Object;)VA D C9(Lcom/dexels/mongodb/sink/MongodbSinkTask$TopicElement;)VFA J '(I( InnerClasses TopicElement OperationBuilderR%java/lang/invoke/MethodHandles$LookupTjava/lang/invoke/MethodHandlesLookupEntry NestMembers!       7Y!#)+ ? @, /*-+5, ./015 2Y45+I,  ./78 9 ,*+:<BDJNMPYRT)W+Y+_<BM+a<BN+c<B:+e<B:*+g<Bh*+j<Bk*+m<Bn*+p<Bqw*+y<Bz|~:|~:*-*,:*Y6 7 B:  B: *  W  ñ+bVWX#Z.]:^F_S``boc~defhijkmopqro+t, ,./, :FbS`frfRC #  ,rf+X =BBBB3  >YYYSSYSLٻY*߶+M,+& xyx#|&}1~58{9, >b#9 T *nY*w*z*k*h++, ./  + M+BN+:,,"Y*-$Y&-(.1*4:6:<>,DM,HN:RYT:&-VZ\Y^VW"Y*-_Y&-(aYcdh1+B)CKSgs~,R./klmnKqo sIp~>qrKqossIpt) BB#ru vZSwY+yMYN,{*-Y:W-:B:-<=:*<: 6 *  : *< W~: )  Ϲ:D: )Y ܸJSY SY JSY S: ) 9+^ "-6=Yf~,9;HR, S./S JB6Yf~  g 5 ;  4S JBf M= =B=B=B=B@ =B=B="!B! q ) J++!,*"./""!8 G+,./ L* *+, ./ =*+<*+YW*+<=M,++ W+ -<,=$%-& -& '(F *).+,  0  1234 ;<?@;BEG;HKLM*"N O@PQSU*=V W"