[rocketmq-apis] branch v2 updated: Allow send batched messages

[lizhanhui]

This is an automated email from the ASF dual-hosted git repository.

lizhanhui pushed a commit to branch v2
in repository https://gitbox.apache.org/repos/asf/rocketmq-apis.git


The following commit(s) were added to refs/heads/v2 by this push:
     new 1915957  Allow send batched messages
1915957 is described below

commit 191595729e1b33e9c4ac95b3331e92384680a6fe
Author: Li Zhanhui <lizhan...@gmail.com>
AuthorDate: Mon Mar 21 07:07:21 2022 +0000

    Allow send batched messages
---
 apache/rocketmq/v2/definition.proto | 5 +++++
 apache/rocketmq/v2/service.proto    | 5 ++---
 2 files changed, 7 insertions(+), 3 deletions(-)

diff --git a/apache/rocketmq/v2/definition.proto 
b/apache/rocketmq/v2/definition.proto
index 99d0b1e..27ed3b5 100644
--- a/apache/rocketmq/v2/definition.proto
+++ b/apache/rocketmq/v2/definition.proto
@@ -321,4 +321,9 @@ enum QueryOffsetPolicy {
 
   // Use this option if time-based seek is targeted.
   TIME_POINT = 3;
+}
+
+message SendReceipt {
+  string message_id = 1;
+  string transaction_id = 2;
 }
\ No newline at end of file
diff --git a/apache/rocketmq/v2/service.proto b/apache/rocketmq/v2/service.proto
index e7bc950..27a5865 100644
--- a/apache/rocketmq/v2/service.proto
+++ b/apache/rocketmq/v2/service.proto
@@ -70,14 +70,13 @@ message QueryRouteResponse {
 }
 
 message SendMessageRequest {
-  Message message = 1;
+  repeated Message message = 1;
   Partition partition = 2;
 }
 
 message SendMessageResponse {
   ResponseCommon common = 1;
-  string message_id = 2;
-  string transaction_id = 3;
+  repeated SendReceipt receipts = 2;
 }
 
 message QueryAssignmentRequest {