diff --git a/cdap-messaging-spi/src/main/java/io/cdap/cdap/messaging/spi/MessagingService.java b/cdap-messaging-spi/src/main/java/io/cdap/cdap/messaging/spi/MessagingService.java
index 8f2d5ae82eed..b65520f93d97 100644
--- a/cdap-messaging-spi/src/main/java/io/cdap/cdap/messaging/spi/MessagingService.java
+++ b/cdap-messaging-spi/src/main/java/io/cdap/cdap/messaging/spi/MessagingService.java
@@ -119,6 +119,7 @@ RollbackDetail publish(StoreRequest request)
    * @throws IOException if failed to store messages
    * @throws ServiceUnavailableException if the messaging service is not available
    */
+  @Deprecated
   void storePayload(StoreRequest request)
       throws TopicNotFoundException, IOException, UnauthorizedException;
 
@@ -132,6 +133,7 @@ void storePayload(StoreRequest request)
    * @throws IOException if failed to rollback changes
    * @throws ServiceUnavailableException if the messaging service is not available
    */
+  @Deprecated
   void rollback(TopicId topicId, RollbackDetail rollbackDetail)
       throws TopicNotFoundException, IOException, UnauthorizedException;
 
diff --git a/cdap-messaging-spi/src/main/java/io/cdap/cdap/messaging/spi/RollbackDetail.java b/cdap-messaging-spi/src/main/java/io/cdap/cdap/messaging/spi/RollbackDetail.java
index aed60da66bc2..d907fe8cd01a 100644
--- a/cdap-messaging-spi/src/main/java/io/cdap/cdap/messaging/spi/RollbackDetail.java
+++ b/cdap-messaging-spi/src/main/java/io/cdap/cdap/messaging/spi/RollbackDetail.java
@@ -19,6 +19,7 @@
 /**
  * This interface represents information needed to rollback message published transactionally.
  */
+@Deprecated
 public interface RollbackDetail {
 
   /**
diff --git a/cdap-messaging-spi/src/main/java/io/cdap/cdap/messaging/spi/StoreRequest.java b/cdap-messaging-spi/src/main/java/io/cdap/cdap/messaging/spi/StoreRequest.java
index 7e4ee42bb510..85eb2d612d33 100644
--- a/cdap-messaging-spi/src/main/java/io/cdap/cdap/messaging/spi/StoreRequest.java
+++ b/cdap-messaging-spi/src/main/java/io/cdap/cdap/messaging/spi/StoreRequest.java
@@ -28,14 +28,17 @@ public interface StoreRequest extends Iterable<byte[]> {
   TopicId getTopicId();
 
   /** Returns {@code true} if the message should be published transactionally. */
+  @Deprecated
   boolean isTransactional();
 
   /**
    * Returns the transaction write pointer if the message is going to be published transactionally,
    * that is when {@link #isTransactional()} returns {@code true}.
    */
+  @Deprecated
   long getTransactionWritePointer();
 
   /** Returns {@code true} if there is payload in this request. */
+  @Deprecated
   boolean hasPayload();
 }