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

Posted to commits@inlong.apache.org by al...@apache.org on 2022/02/23 02:58:26 UTC

[incubator-inlong] branch master updated (8368cca -> 70d78d0)

This is an automated email from the ASF dual-hosted git repository.

aloyszhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git.


    from 8368cca  [INLONG-2663][Manager] Fix inconsistent fields in manager-client module (#2665)
     add 70d78d0  [INLONG-2653][Manager] Support Kafka source in InLong Stream. (#2653) (#2658)

No new revisions were added by this update.

Summary of changes:
 .../common/pojo/source/binlog/BinlogSourceDTO.java |  2 +-
 .../kafka/KafkaSourceDTO.java}                     | 20 ++++----
 .../kafka/KafkaSourceListResponse.java}            | 10 ++--
 .../kafka/KafkaSourceRequest.java}                 | 14 +++---
 .../kafka/KafkaSourceResponse.java}                | 13 +++---
 .../KafkaStreamSourceOperation.java}               | 53 +++++++++-------------
 6 files changed, 49 insertions(+), 63 deletions(-)
 copy inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/{sink/kafka/KafkaSinkDTO.java => source/kafka/KafkaSourceDTO.java} (80%)
 copy inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/{sink/kafka/KafkaSinkListResponse.java => source/kafka/KafkaSourceListResponse.java} (81%)
 copy inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/{sink/kafka/KafkaSinkRequest.java => source/kafka/KafkaSourceRequest.java} (81%)
 copy inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/{sink/kafka/KafkaSinkResponse.java => source/kafka/KafkaSourceResponse.java} (80%)
 copy inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/{binlog/BinlogStreamSourceOperation.java => kafka/KafkaStreamSourceOperation.java} (80%)