You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by do...@apache.org on 2022/02/10 11:06:59 UTC
[incubator-inlong] branch master updated (9d11fcf -> 8a5dea1)
This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git.
from 9d11fcf [INLONG-2441] [Inlong-Audit] Modify the version of audit protobuf (#2444)
add 8a5dea1 [INLONG-1896][Feature][Sort] Inlong-Sort-Standalone support to sort the events to Kafka clusters. (#2359)
No new revisions were added by this update.
Summary of changes:
inlong-sort-standalone/pom.xml | 9 +-
.../sort/standalone/metrics/SortMetricItem.java | 42 +++--
.../KafkaFederationSink.java} | 75 ++++----
.../KafkaFederationSinkContext.java} | 83 +++++----
.../sink/kafka/KafkaFederationWorker.java | 171 ++++++++++++++++++
.../sink/kafka/KafkaProducerCluster.java | 191 +++++++++++++++++++++
.../sink/kafka/KafkaProducerFederation.java | 162 +++++++++++++++++
.../sink/pulsar/PulsarProducerCluster.java | 32 +---
8 files changed, 649 insertions(+), 116 deletions(-)
copy inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/{pulsar/PulsarFederationSink.java => kafka/KafkaFederationSink.java} (64%)
copy inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/{pulsar/PulsarFederationSinkContext.java => kafka/KafkaFederationSinkContext.java} (73%)
create mode 100644 inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/kafka/KafkaFederationWorker.java
create mode 100644 inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/kafka/KafkaProducerCluster.java
create mode 100644 inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/kafka/KafkaProducerFederation.java