This is an automated email from the ASF dual-hosted git repository. gosonzhang pushed a commit to branch revert-1543-INLONG-1541 in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git
commit d36707fc7da01274ca2556916150dd29948fb2be Author: gosonzhang <[email protected]> AuthorDate: Mon Sep 13 12:17:10 2021 +0000 Revert "[INLONG-1541] Add replica node request and response define in the BrokerService.proto (#1543)" This reverts commit a45f10903dd64687d37152a15f4537a0f4234ca8. --- .../tubemq-core/src/main/proto/BrokerService.proto | 96 ---------------------- 1 file changed, 96 deletions(-) diff --git a/inlong-tubemq/tubemq-core/src/main/proto/BrokerService.proto b/inlong-tubemq/tubemq-core/src/main/proto/BrokerService.proto index 2c7a430..87de27e 100644 --- a/inlong-tubemq/tubemq-core/src/main/proto/BrokerService.proto +++ b/inlong-tubemq/tubemq-core/src/main/proto/BrokerService.proto @@ -27,10 +27,6 @@ message TransferedMessage { required int32 checkSum = 2; required bytes payLoadData = 3; required int32 flag = 4; - optional int32 partitionId = 5; - optional int32 indexKeyCode = 6; - optional int32 reportAddr = 7; - optional int64 recvTimeInMs = 8; } message AuthorizedInfo { @@ -144,95 +140,3 @@ message CommitOffsetResponseB2C { optional int64 currOffset=4; optional int64 maxOffset = 5; } - -message OffsetViewInfo{ - required int64 indexStartOffset = 1; - required int64 indexEndOffset = 2; - required int64 dataStartOffset = 3; - required int64 dataEndOffset = 4; -} - -message RegisterRequestF2L { - required string replicaId = 1; - required string groupName = 2; - required string topicName = 3; - required int32 storeId = 4; - required OffsetViewInfo offsetViewInfo = 5; - optional int64 reqOffset = 6; - optional AuthorizedInfo authInfo = 7; -} - -message RegisterResponseL2F { - required bool success = 1; - required int32 errCode = 2; - required string errMsg = 3; - required OffsetViewInfo offsetViewInfo = 4; - optional int64 readOffset = 5; -} - -message HeartBeatRequestF2L { - required string replicaId = 1; - required string groupName = 2; - repeated string storeHBInfo = 3; - optional AuthorizedInfo authInfo = 4; -} - -message HeartBeatResponseL2F { - required bool success = 1; - required int32 errCode = 2; - required string errMsg = 3; - optional bool hasPartFailure = 4; - repeated string storeHBInfo = 5; - optional bool requireAuth = 6; -} - -message CloseRequestF2L{ - required string replicaId = 1; - required string groupName = 2; - required string topicName = 3; - required int32 storeId = 4; - optional AuthorizedInfo authInfo = 5; -} - -message CloseResponseL2F{ - required bool success = 1; - required int32 errCode = 2; - required string errMsg = 3; -} - -message GetMessageRequestF2L { - required string replicaId = 1; - required string groupName = 2; - required string topicName = 3; - required int32 storeId = 4; - optional bool lastPackConsumed = 5; -} - -message GetMessageResponseL2F { - required bool success = 1; - required int32 errCode = 2; - optional string errMsg = 3; - repeated TransferedMessage messages = 4; - optional int64 currReadOffset = 5; - optional int64 currDataDlt = 6; - optional int64 maxIndexOffset = 7; - optional int64 maxDataOffset = 8; -} - -message CommitOffsetRequestF2L { - required string replicaId = 1; - required string groupName = 2; - required string topicName = 3; - required int32 storeId = 4; - required bool lastPackConsumed = 5; -} - -message CommitOffsetResponseL2F { - required bool success = 1; - required int32 errCode = 2; - required string errMsg = 3; - optional int64 currReadOffset = 4; - optional int64 currDataDlt = 5; - optional int64 maxIndexOffset = 6; - optional int64 maxDataOffset = 7; -}
