7"com/dexels/kafka/impl/KafkaMessagejava/lang/Object'com/dexels/pubsub/rx2/api/PubSubMessagekeyLjava/lang/String;value[B timestampJtopicoffset partitionI committerLjava/util/function/BiConsumer; SignatureYLjava/util/function/BiConsumer;T(Lorg/apache/kafka/clients/consumer/ConsumerRecord;Ljava/util/function/BiConsumer;)V(Lorg/apache/kafka/clients/consumer/ConsumerRecord;Ljava/util/function/BiConsumer;)VCode  ()V 0org/apache/kafka/clients/consumer/ConsumerRecord ()Ljava/lang/String; "  $ %()Ljava/lang/Object;'java/lang/String )  + % . 0 1()J 3 5 1 7  9 :()I <  > LineNumberTableLocalVariableTablethis$Lcom/dexels/kafka/impl/KafkaMessage;record2Lorg/apache/kafka/clients/consumer/ConsumerRecord;LocalVariableTypeTableHLorg/apache/kafka/clients/consumer/ConsumerRecord;()[B()Ljava/util/Optional;*()Ljava/util/Optional; KMLjava/util/Optional NOof((Ljava/lang/Object;)Ljava/util/Optional;toStringRnull &T U([B)V StackMapTable withTopic?(Ljava/util/Optional;)Lcom/dexels/pubsub/rx2/api/PubSubMessage;S(Ljava/util/Optional;)Lcom/dexels/pubsub/rx2/api/PubSubMessage; []\)com/dexels/pubsub/rx2/factory/PubSubTools W^h(Lcom/dexels/pubsub/rx2/api/PubSubMessage;Ljava/util/Optional;)Lcom/dexels/pubsub/rx2/api/PubSubMessage;Ljava/util/Optional;(Ljava/util/Optional;withKey=(Ljava/lang/String;)Lcom/dexels/pubsub/rx2/api/PubSubMessage; [d aef(Lcom/dexels/pubsub/rx2/api/PubSubMessage;Ljava/lang/String;)Lcom/dexels/pubsub/rx2/api/PubSubMessage; withValue-([B)Lcom/dexels/pubsub/rx2/api/PubSubMessage; [i fjV(Lcom/dexels/pubsub/rx2/api/PubSubMessage;[B)Lcom/dexels/pubsub/rx2/api/PubSubMessage; withTimestamp,(J)Lcom/dexels/pubsub/rx2/api/PubSubMessage; [n koU(Lcom/dexels/pubsub/rx2/api/PubSubMessage;J)Lcom/dexels/pubsub/rx2/api/PubSubMessage;+()Ljava/util/Optional; rtsjava/lang/Integer uvvalueOf(I)Ljava/lang/Integer;(()Ljava/util/Optional; y{zjava/lang/Long u|(J)Ljava/lang/Long;commit&org/apache/kafka/common/TopicPartition ~ (Ljava/lang/String;I)V java/util/function/BiConsumer accept'(Ljava/lang/Object;Ljava/lang/Object;)V SourceFileKafkaMessage.java!     @**+!*+#&(*+*,-*+/2*+46*+8;*,=?&  "*2:?@ @AB@CD@E@CF@ /*(?#@ AB G/*-?(@ AB HI2*!J?-@ AB 1/*2?2@ ABP Q*-Q&Y*-S?67 8@ ABV WXYL*+Z?=@AB _E  `ab:*+c?B@ABafg:*+h?G@AB kl:*m?L@AB Hp5 *;qJ?Q@  ABHw5 *6xJ?V@  AB}N *=~Y*!*;*6x? [\@  AB