You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@inlong.apache.org by he...@apache.org on 2023/01/15 15:04:35 UTC

[inlong] branch master updated (bd77b2677 -> ee21063a7)

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