You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by go...@apache.org on 2022/01/21 01:59:32 UTC
[incubator-inlong] branch master updated (897c895 -> 1458d28)
This is an automated email from the ASF dual-hosted git repository.
gosonzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git.
from 897c895 [INLONG-1950][DataProxy] DataProxy add supporting to udp protocol for reporting data (#2185)
add 1458d28 [INLONG-2247]Read the consume group offset and store to the specified topic (#2248)
No new revisions were added by this update.
Summary of changes:
.../inlong/tubemq/server/broker/BrokerConfig.java | 33 +++-
.../tubemq/server/broker/BrokerServiceServer.java | 184 +++++++++++++++++++++
.../inlong/tubemq/server/broker/TubeBroker.java | 7 +
.../broker/metadata/BrokerMetadataManager.java | 58 +++++--
.../server/broker/metadata/TopicMetadata.java | 39 ++++-
.../broker/msgstore/MessageStoreManager.java | 50 +++++-
.../server/broker/msgstore/StoreService.java | 6 +
.../server/broker/offset/DefaultOffsetManager.java | 41 ++++-
.../server/broker/offset/OffsetRecordInfo.java | 102 ++++++++++++
.../server/broker/offset/OffsetRecordService.java | 95 +++++++++++
.../tubemq/server/broker/offset/OffsetService.java | 2 +
.../tubemq/server/broker/offset/RecordItem.java | 64 +++++++
.../tubemq/server/common/TServerConstants.java | 7 +
.../server/common/paramcheck/PBParameterUtils.java | 17 +-
14 files changed, 668 insertions(+), 37 deletions(-)
create mode 100644 inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/offset/OffsetRecordInfo.java
create mode 100644 inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/offset/OffsetRecordService.java
create mode 100644 inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/offset/RecordItem.java