7%,com/dexels/mongodb/sink/MongodbSinkConnector+org/apache/kafka/connect/sink/SinkConnectorlogLorg/slf4j/Logger;CONNECTIONSTRINGLjava/lang/String; ConstantValue connectionString BULK_SIZE bulk.sizeDATABASEmongodb.database COLLECTIONSmongodb.collectionsTOPICStopicsSINKIDsinkid GENERATION generation INSTANCENAME  instanceNameSINKNAME#sinkNameTENANT&tenant DEPLOYMENT) deploymentbulkSizedatabase collectionsLjava/util/Optional; Signature(Ljava/util/Optional;()VCode 465org/slf4j/LoggerFactory 78 getLogger%(Ljava/lang/Class;)Lorg/slf4j/Logger; : LineNumberTableLocalVariableTable ? =1 ACBjava/lang/System DEerrLjava/io/PrintStream;Gmongodb sink connector IKJjava/io/PrintStream LMprintln(Ljava/lang/String;)Vthis.Lcom/dexels/mongodb/sink/MongodbSinkConnector;version()Ljava/lang/String; SUT+org/apache/kafka/common/utils/AppInfoParser VQ getVersionstart(Ljava/util/Map;)V8(Ljava/util/Map;)V[java/lang/StringBuilder]Parsing configuration: Z_ =M Za bcappend-(Ljava/lang/Object;)Ljava/lang/StringBuilder; Ze fQtoString hjiorg/slf4j/Logger kMinfo mon java/util/Map pqget&(Ljava/lang/Object;)Ljava/lang/Object;sjava/lang/String u * rw xyisEmpty()Z{0org/apache/kafka/connect/errors/ConnectException}Missing bulk.size config z_  Missing connectionString config  +  ,  , r split'(Ljava/lang/String;)[Ljava/lang/String;DThe number of topics should be the same as the number of collections      # java/util/Optional  ofNullable((Ljava/lang/Object;)Ljava/util/Optional;  &-  )  dumpConfiguration$(Ljava/util/Map;Lorg/slf4j/Logger;)VmapLjava/util/Map;LocalVariableTypeTable5Ljava/util/Map; StackMapTableJ(Ljava/util/Map;Lorg/slf4j/Logger;)V&Starting connector with configuration: h Mtrace m entrySet()Ljava/util/Set;  java/util/Set iterator()Ljava/util/Iterator; java/util/Iterator next()Ljava/lang/Object;java/util/Map$Entry{}: {} getKey getValue h 9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V yhasNextentryLjava/util/Map$Entry;;Ljava/util/Map$Entry; taskClass()Ljava/lang/Class;?()Ljava/lang/Class<+Lorg/apache/kafka/connect/connector/Task;>;'com/dexels/mongodb/sink/MongodbSinkTask taskConfigs(I)Ljava/util/List;J(I)Ljava/util/List;>;java/util/ArrayList ? java/util/Arrays asList%([Ljava/lang/Object;)Ljava/util/List; java/util/List size()I java/lang/Math min(II)I ,org/apache/kafka/connect/util/ConnectorUtils groupPartitions#(Ljava/util/List;I)Ljava/util/List;java/util/HashMap ? m put8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; y isPresent  p  p(I)Ljava/lang/Object;java/lang/Iterable r   join@(Ljava/lang/CharSequence;Ljava/lang/Iterable;)Ljava/lang/String;   add(Ljava/lang/Object;)ZmaxTasksIconfigsLjava/util/List;coll numGroups dbsGrouped topicsGroupediconfigGLjava/util/List;>;$Ljava/util/List;6Ljava/util/List;>;stop,()Lorg/apache/kafka/common/config/ConfigDef;(org/apache/kafka/common/config/ConfigDef ? SourceFileMongodbSinkConnector.java InnerClassesEntry!           ! "$ %' ( *+, #&-./) 012- 39; &<=12? *>@FH;45 6<  NOPQ2.R;>< NOWX.Y29ZY\^+`dg*+ lrt*t *tv zY|~*+ lr* *v zY~*+lr*+lr*+lr** zY~*+lr*+lr*+"lr*+%lr*+(lr*+9;NIK'L8MBOQPbQlT{UVXY\]^_`bc<NO  8  M.2B,+:"N,--ڱ;fg#h7gAj<*BNOBB#B#mh.2-ְ;s< NO.2c YM*N-6-:*::6λY:   *tW  *W *W *W *W "*W* %*rW (*W W W,  W1,;Z!)7@FO]ky<f NO!)7@CO >)7@O 'F zmO12+;< NO22Y ;< NO!"# m$