This is an automated email from the ASF dual-hosted git repository.
zhoubo pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git
from b0624d57 Revert "[ISSUE #424] Adjust the order in which
WorkerSourceTask topics are acquired (#426)" (#429)
add e8366cd3 [ISSUE #397] Support compaction topic (#430)
No new revisions were added by this update.
Summary of changes:
{reporter-api => metric-exporter}/pom.xml | 4 +-
.../connect/metrics/AutoConfiguration.java | 0
.../apache/rocketmq/connect/metrics/IReporter.java | 0
.../rocketmq/connect/metrics/MetricName.java | 0
.../rocketmq/connect/metrics/MetricUtils.java | 0
.../rocketmq/connect/metrics/MetricsReporter.java | 0
.../connect/metrics/ScheduledMetricsReporter.java | 0
.../metrics/reporter/RocketMQClientUtil.java | 0
.../reporter/RocketMQScheduledReporter.java | 0
.../connect/metrics/stats/AbstractHistogram.java | 0
.../apache/rocketmq/connect/metrics/stats/Avg.java | 0
.../connect/metrics/stats/CumulativeCount.java | 0
.../apache/rocketmq/connect/metrics/stats/Max.java | 0
.../rocketmq/connect/metrics/stats/Measure.java | 0
.../apache/rocketmq/connect/metrics/stats/Min.java | 0
.../rocketmq/connect/metrics/stats/Percentile.java | 0
.../rocketmq/connect/metrics/stats/Rate.java | 0
.../connect/metrics/stats/RateByMinutes.java | 0
.../rocketmq/connect/metrics/stats/RatioValue.java | 0
.../rocketmq/connect/metrics/stats/Stat.java | 0
.../rocketmq/connect/metrics/stats/Value.java | 0
pom.xml | 12 +-
rocketmq-connect-runtime/pom.xml | 7 +-
.../connect/runtime/DistributedConnectStartup.java | 17 +-
.../connect/runtime/StandaloneConnectStartup.java | 14 +-
.../connect/runtime/config/WorkerConfig.java | 48 +-
.../connectorwrapper/RecordOffsetManagement.java | 3 +-
.../runtime/connectorwrapper/TargetState.java | 6 -
.../connect/runtime/connectorwrapper/Worker.java | 14 +-
.../runtime/connectorwrapper/WorkerConnector.java | 64 +--
.../controller/AbstractConnectController.java | 85 +--
.../service/AbstractConfigManagementService.java | 490 +++++++++++++++-
...java => AbstractPositionManagementService.java} | 274 +++------
...pl.java => AbstractStateManagementService.java} | 224 ++------
.../runtime/service/ClusterManagementService.java | 7 -
.../service/ClusterManagementServiceImpl.java | 5 -
.../runtime/service/ConfigManagementService.java | 7 +-
.../service/ConfigManagementServiceImpl.java | 618 ---------------------
.../IChangeNotifier.java} | 21 +-
.../ICommonConfiguration.java} | 8 +-
.../runtime/service/PositionManagementService.java | 7 +-
.../runtime/service/StateManagementService.java | 7 -
.../local/LocalConfigManagementServiceImpl.java | 163 ++++++
.../local/LocalPositionManagementServiceImpl.java | 122 ++++
.../local/LocalStateManagementServiceImpl.java | 193 +++++++
.../memory/FilePositionManagementServiceImpl.java | 21 +-
.../memory/MemoryClusterManagementServiceImpl.java | 5 -
.../memory/MemoryConfigManagementServiceImpl.java | 21 +-
.../memory/MemoryStateManagementServiceImpl.java | 10 -
.../RocketMqConfigManagementServiceImpl.java | 68 +++
.../RocketMqPositionManagementServiceImpl.java | 84 +++
.../RocketMqStateManagementServiceImpl.java | 113 ++++
.../connect/runtime/utils/ConnectUtil.java | 149 ++++-
.../rocketmq/connect/runtime/utils/RetryUtil.java | 208 +++++++
.../connect/runtime/utils/ServiceProviderUtil.java | 111 ++--
.../runtime/utils/datasync/BrokerBasedLog.java | 240 ++++++--
...onnect.runtime.service.ClusterManagementService | 4 +-
...connect.runtime.service.ConfigManagementService | 5 +-
...nnect.runtime.service.PositionManagementService | 5 +-
....connect.runtime.service.StateManagementService | 3 +-
.../src/main/resources/connect-distributed.conf | 14 +
.../connectorwrapper/WorkerDirectTaskTest.java | 8 +-
.../connectorwrapper/WorkerSinkTaskTest.java | 9 +-
.../runtime/connectorwrapper/WorkerTest.java | 4 +-
.../testimpl/TestPositionManageServiceImpl.java | 6 -
.../DistributedConnectControllerTest.java | 7 +-
.../distributed/TestConfigManagementService.java | 8 -
...ervice.java => TestStateManagementService.java} | 64 +--
.../StandaloneConnectControllerTest.java | 1 -
.../connect/runtime/rest/RestHandlerTest.java | 4 +-
.../service/ConfigManagementServiceImplTest.java | 46 +-
.../service/DefaultConnectorContextTest.java | 127 +++--
.../service/PositionManagementServiceImplTest.java | 49 +-
.../store/PositionStorageReaderImplTest.java | 35 +-
.../runtime/store/PositionStorageWriterTest.java | 4 +-
.../connect/runtime/utils/ConnectUtilTest.java | 25 -
.../runtime/utils/ServiceProviderUtilTest.java | 27 +-
.../runtime/utils/datasync/BrokerBasedLogTest.java | 46 +-
78 files changed, 2445 insertions(+), 1506 deletions(-)
rename {reporter-api => metric-exporter}/pom.xml (99%)
rename {reporter-api =>
metric-exporter}/src/main/java/org/apache/rocketmq/connect/metrics/AutoConfiguration.java
(100%)
rename {reporter-api =>
metric-exporter}/src/main/java/org/apache/rocketmq/connect/metrics/IReporter.java
(100%)
rename {reporter-api =>
metric-exporter}/src/main/java/org/apache/rocketmq/connect/metrics/MetricName.java
(100%)
rename {reporter-api =>
metric-exporter}/src/main/java/org/apache/rocketmq/connect/metrics/MetricUtils.java
(100%)
rename {reporter-api =>
metric-exporter}/src/main/java/org/apache/rocketmq/connect/metrics/MetricsReporter.java
(100%)
rename {reporter-api =>
metric-exporter}/src/main/java/org/apache/rocketmq/connect/metrics/ScheduledMetricsReporter.java
(100%)
rename {reporter-api =>
metric-exporter}/src/main/java/org/apache/rocketmq/connect/metrics/reporter/RocketMQClientUtil.java
(100%)
rename {reporter-api =>
metric-exporter}/src/main/java/org/apache/rocketmq/connect/metrics/reporter/RocketMQScheduledReporter.java
(100%)
rename {reporter-api =>
metric-exporter}/src/main/java/org/apache/rocketmq/connect/metrics/stats/AbstractHistogram.java
(100%)
rename {reporter-api =>
metric-exporter}/src/main/java/org/apache/rocketmq/connect/metrics/stats/Avg.java
(100%)
rename {reporter-api =>
metric-exporter}/src/main/java/org/apache/rocketmq/connect/metrics/stats/CumulativeCount.java
(100%)
rename {reporter-api =>
metric-exporter}/src/main/java/org/apache/rocketmq/connect/metrics/stats/Max.java
(100%)
rename {reporter-api =>
metric-exporter}/src/main/java/org/apache/rocketmq/connect/metrics/stats/Measure.java
(100%)
rename {reporter-api =>
metric-exporter}/src/main/java/org/apache/rocketmq/connect/metrics/stats/Min.java
(100%)
rename {reporter-api =>
metric-exporter}/src/main/java/org/apache/rocketmq/connect/metrics/stats/Percentile.java
(100%)
rename {reporter-api =>
metric-exporter}/src/main/java/org/apache/rocketmq/connect/metrics/stats/Rate.java
(100%)
rename {reporter-api =>
metric-exporter}/src/main/java/org/apache/rocketmq/connect/metrics/stats/RateByMinutes.java
(100%)
rename {reporter-api =>
metric-exporter}/src/main/java/org/apache/rocketmq/connect/metrics/stats/RatioValue.java
(100%)
rename {reporter-api =>
metric-exporter}/src/main/java/org/apache/rocketmq/connect/metrics/stats/Stat.java
(100%)
rename {reporter-api =>
metric-exporter}/src/main/java/org/apache/rocketmq/connect/metrics/stats/Value.java
(100%)
rename
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/{PositionManagementServiceImpl.java
=> AbstractPositionManagementService.java} (58%)
rename
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/{StateManagementServiceImpl.java
=> AbstractStateManagementService.java} (66%)
delete mode 100644
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/ConfigManagementServiceImpl.java
copy
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/{controller/distributed/DistributedConfig.java
=> service/IChangeNotifier.java} (65%)
copy
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/{connectorwrapper/WorkerState.java
=> service/ICommonConfiguration.java} (86%)
create mode 100644
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/local/LocalConfigManagementServiceImpl.java
create mode 100644
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/local/LocalPositionManagementServiceImpl.java
create mode 100644
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/local/LocalStateManagementServiceImpl.java
create mode 100644
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/rocketmq/RocketMqConfigManagementServiceImpl.java
create mode 100644
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/rocketmq/RocketMqPositionManagementServiceImpl.java
create mode 100644
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/rocketmq/RocketMqStateManagementServiceImpl.java
create mode 100755
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/RetryUtil.java
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/controller/distributed/{TestConfigManagementService.java
=> TestStateManagementService.java} (50%)
