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/15 10:21:38 UTC

[incubator-inlong] branch master updated (a21bb1b -> d80bc93)

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 a21bb1b  [INLONG-2379] DataProxy support Pulsar sink of PB compression cache message protocol. (#2502)
     add d80bc93  [INLONG-2380] DataProxy support Kafka sink of PB compression cache message protocol. (#2503)

No new revisions were added by this update.

Summary of changes:
 .../KafkaClusterProducer.java}                     | 139 ++++++---------------
 .../KafkaZoneProducer.java}                        |  29 +++--
 .../KafkaZoneSink.java}                            |  18 +--
 .../KafkaZoneSinkContext.java}                     |  12 +-
 .../KafkaZoneWorker.java}                          |  20 +--
 5 files changed, 79 insertions(+), 139 deletions(-)
 copy inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/{tubezone/TubeClusterProducer.java => kafkazone/KafkaClusterProducer.java} (55%)
 copy inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/{pulsarzone/PulsarZoneProducer.java => kafkazone/KafkaZoneProducer.java} (81%)
 copy inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/{tubezone/TubeZoneSink.java => kafkazone/KafkaZoneSink.java} (88%)
 copy inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/{tubezone/TubeZoneSinkContext.java => kafkazone/KafkaZoneSinkContext.java} (96%)
 copy inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/{tubezone/TubeZoneWorker.java => kafkazone/KafkaZoneWorker.java} (80%)