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%)
