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