This is an automated email from the ASF dual-hosted git repository.
healchow pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from bd77b2677 [INLONG-7234][Audit] Add log4j for audit-store (#7235)
add ee21063a7 [INLONG-7231][DataProxy] Add selector policy of cache
cluster list (#7236)
No new revisions were added by this update.
Summary of changes:
...ueHandler.java => AllCacheClusterSelector.java} | 32 +++-----
.../inlong/dataproxy/sink/mq/BatchPackManager.java | 4 +-
.../dataproxy/sink/mq/CacheClusterSelector.java | 15 ++--
.../sink/mq/MessageQueueZoneProducer.java | 55 +++++++-------
.../dataproxy/sink/mq/MessageQueueZoneSink.java | 7 +-
.../sink/mq/MessageQueueZoneSinkContext.java | 42 +++++++++--
.../dataproxy/sink/mq/MessageQueueZoneWorker.java | 10 +--
.../sink/mq/RandomCacheClusterSelector.java | 88 ++++++++++++++++++++++
.../dataproxy/sink/mq/kafka/KafkaHandler.java | 42 +++++++----
.../dataproxy/sink/mq/pulsar/PulsarHandler.java | 46 ++++++-----
.../inlong/dataproxy/sink/mq/tube/TubeHandler.java | 42 +++++++----
11 files changed, 260 insertions(+), 123 deletions(-)
copy
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mq/{MessageQueueHandler.java
=> AllCacheClusterSelector.java} (71%)
copy
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/RoleService.java
=>
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mq/CacheClusterSelector.java
(75%)
create mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mq/RandomCacheClusterSelector.java
