71com/dexels/kafka/streams/base/StreamConfigurationjava/lang/Object kafkaHostsLjava/lang/String; deploymentsinksLjava/util/Map; SignatureXLjava/util/Map; adminClient,Lorg/apache/kafka/clients/admin/AdminClient;maxWaitImaxSizereplicationFactorconfig5Ljava/util/Map;9(Ljava/lang/String;Ljava/util/Map;Ljava/lang/String;III)V(Ljava/lang/String;Ljava/util/Map;Ljava/lang/String;III)VCode  ()V  java/util/HashMap  !(Ljava/util/Map;)V #%$java/util/Collections &'unmodifiableMap (Ljava/util/Map;)Ljava/util/Map; )  +   .  0bootstrap.servers 243 java/util/Map 56put8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;8 client.id :<;java/util/UUID => randomUUID()Ljava/util/UUID; :@ ABtoString()Ljava/lang/String; D  F  H LineNumberTableLocalVariableTablethis3Lcom/dexels/kafka/streams/base/StreamConfiguration;LocalVariableTypeTable.()Lorg/apache/kafka/clients/admin/AdminClient; P RTS*org/apache/kafka/clients/admin/AdminClient UVcreate=(Ljava/util/Map;)Lorg/apache/kafka/clients/admin/AdminClient; StackMapTablekafkaSubscribeMaxWait()IkafkaSubscribeMaxSizekafkaReplicationFactor()Ljava/util/Map;Z()Ljava/util/Map;sink((Ljava/lang/String;)Ljava/util/Optional;_(Ljava/lang/String;)Ljava/util/Optional; 2b cdget&(Ljava/lang/Object;)Ljava/lang/Object;f3com/dexels/kafka/streams/api/sink/SinkConfiguration hjijava/util/Optional kl ofNullable((Ljava/lang/Object;)Ljava/util/Optional;nametenants()Ljava/util/List;&()Ljava/util/List;r TENANT_MASTER tvujava/lang/System wxgetenv&(Ljava/lang/String;)Ljava/lang/String; hz {| isPresent()Z h~ c()Ljava/lang/Object;java/lang/String, split'(Ljava/lang/String;)[Ljava/lang/String; java/util/Arrays asList%([Ljava/lang/Object;)Ljava/util/List; # o emptyListtenantDefinitionLjava/util/Optional;(Ljava/util/Optional; SourceFileStreamConfiguration.java!        Z**+*Y,"(*-**Y,-*-/+1W*-79?1W*C*E*GI.   !("5#G%M&S'Y(JHZKLZZ ZZZZM Z  NR*O**-QO*OI+,.J KLWB/*I2J KLXY/*CI6J KLZY/*EI:J KL[Y/*GI>J KL\ ]/*(IBJ KL^_ `E*(+aegIFJKLmB/**IJJ KLno p$qsgL+y+}IN OP RJ$KL M  W h