7Ecom/dexels/replication/impl/protobuf/FallbackReplicationMessageParserjava/lang/Object3com/dexels/replication/api/ReplicationMessageParserprimary5Lcom/dexels/replication/api/ReplicationMessageParser; secondaryp4Lcom/fasterxml/jackson/core/JsonProcessingException;loggerLorg/slf4j/Logger;()VCode org/slf4j/LoggerFactory  getLogger%(Ljava/lang/Class;)Lorg/slf4j/Logger;  LineNumberTableLocalVariableTablePROTOBUFREPLICATION_MESSAGE_FORMAT !#"java/lang/System $%getenv&(Ljava/lang/String;)Ljava/lang/String; ')(java/lang/String *+equals(Ljava/lang/Object;)Z !- .% getProperty 0 1(Z)VthisGLcom/dexels/replication/impl/protobuf/FallbackReplicationMessageParser; StackMapTable 6 8Acom/dexels/replication/impl/json/JSONReplicationMessageParserImpl 76 ; =Jcom/dexels/replication/impl/protobuf/impl/ProtobufReplicationMessageParser <6 @  useProtobufZ determineType9([B)Lcom/dexels/replication/api/ReplicationMessageParser;data[B<(Ljava/io/InputStream;Ljava/util/List;)Ljava/io/InputStream; Signatures(Ljava/io/InputStream;Ljava/util/List;)Ljava/io/InputStream;Kjava/io/PushbackInputStream JM N(Ljava/io/InputStream;I)V JP QRread([B)I TVUjava/util/List W+add JY Z[unread([B)V]Error: _a`org/slf4j/Logger bcerror*(Ljava/lang/String;Ljava/lang/Throwable;)Vejava/io/IOExceptionLjava/io/InputStream;resultLjava/util/List;pisLjava/io/PushbackInputStream;preeLjava/io/IOException;LocalVariableTypeTableGLjava/util/List;Frjava/io/InputStream parseBytes3([B)Lcom/dexels/replication/api/ReplicationMessage; v CD xzyjava/util/Optional {|empty()Ljava/util/Optional; ~ sG(Ljava/util/Optional;[B)Lcom/dexels/replication/api/ReplicationMessage;[(Ljava/util/Optional;[B)Lcom/dexels/replication/api/ReplicationMessage;sourceLjava/util/Optional;(Ljava/util/Optional;parseMessageList([B)Ljava/util/List;E([B)Ljava/util/List;   parseStreamF(Ljava/io/InputStream;)Lcom/dexels/replication/api/ReplicationMessage;  Z(Ljava/util/Optional;Ljava/io/InputStream;)Lcom/dexels/replication/api/ReplicationMessage;n(Ljava/util/Optional;Ljava/io/InputStream;)Lcom/dexels/replication/api/ReplicationMessage;java/util/LinkedList 6  CG T stream()Ljava/util/stream/Stream; java/util/stream/Stream | findFirst x get()Ljava/lang/Object;  resisparser;(Ljava/util/Optional;Ljava/io/InputStream;)Ljava/util/List;(Ljava/util/Optional;Ljava/io/InputStream;)Ljava/util/List;  serializeMessageList(Ljava/util/List;)[BE(Ljava/util/List;)[B  msgALjava/util/List; serialize3(Lcom/dexels/replication/api/ReplicationMessage;)[B  /Lcom/dexels/replication/api/ReplicationMessage;describeC(Lcom/dexels/replication/api/ReplicationMessage;)Ljava/lang/String;  ((Ljava/util/Optional;[B)Ljava/util/List;m(Ljava/util/Optional;[B)Ljava/util/List;Z(Lcom/dexels/pubsub/rx2/api/PubSubMessage;)Lcom/dexels/replication/api/ReplicationMessage; 'com/dexels/pubsub/rx2/api/PubSubMessage value()[B  st 1com/dexels/replication/factory/ReplicationFactory {1()Lcom/dexels/replication/api/ReplicationMessage; 7com/dexels/replication/api/ReplicationMessage$Operation DELETE9Lcom/dexels/replication/api/ReplicationMessage$Operation; -com/dexels/replication/api/ReplicationMessage  withOperationj(Lcom/dexels/replication/api/ReplicationMessage$Operation;)Lcom/dexels/replication/api/ReplicationMessage; | partition  withPartitionE(Ljava/util/Optional;)Lcom/dexels/replication/api/ReplicationMessage; |offset  withOffset |topic  withSource_kafkapartition java/lang/Integer valueOf(I)Ljava/lang/Integer; x orElse&(Ljava/lang/Object;)Ljava/lang/Object;integer withg(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/String;)Lcom/dexels/replication/api/ReplicationMessage; _kafkaoffset java/lang/Long (J)Ljava/lang/Long;long _kafkakey    key()Ljava/lang/String; string _kafkatopic)Lcom/dexels/pubsub/rx2/api/PubSubMessage; SourceFile%FallbackReplicationMessageParser.javaRuntimeInvisibleAnnotations2Lorg/osgi/service/component/annotations/Component;name#dexels.replication.parser.universalpropertyname=universal version=1 InnerClasses Operation!   ) !f$* &,&/ $#& $234_1-*5*7Y9:*?*7Y9?()*+!,,.-23-AB4! CD*+*?+3*:+3*:*?01 346 7%9*23*EF4 CGHI>oJY+LN:-OW3,*:SW3,*:SW-X,*?SW:\^,*:SW- QTd6 > @AB C+E5F@HFIQJVKbLmN>o23oEfogh eijBkFVlmn ogo4#+JpqTJdstC*+uw+}S23EFsH] *,u+,}Z  23  EFn  H@ *+u+` 23 EF= *w+e 23 EfH-YN*,-:-:jkl#m>-23--Ef%hf# n-%oH.YN*,-:-:+rst#u>.23..Ef&hf# n.&oHQ *?+z 23 hn  ? *?+ 23 ? *?+ 23 HR 23EFn s+*+çŲʹ++++++ + & !,7BXq23E4Js[ss @