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/03/02 09:20:35 UTC

[incubator-inlong] branch master updated (f587c53 -> 7d5fbf0)

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 f587c53  [INLONG-2830][Manager] Support more than one source for a pair of group and streams (#2831)
     add 7d5fbf0  [INLONG-2808][manager]Manager client support kafka sink and fix some problems (#2828)

No new revisions were added by this update.

Summary of changes:
 .../inlong/manager/client/api/sink/KafkaSink.java} | 40 ++++++++++-----
 .../manager/client/api/util/InlongParser.java      | 25 ++++++++-
 .../api/util/InlongStreamSourceTransfer.java       |  8 +--
 .../client/api/util/InlongStreamTransfer.java      | 60 ++++++++++++++++++++--
 .../sink/kafka/KafkaStreamSinkOperation.java       |  8 ++-
 5 files changed, 117 insertions(+), 24 deletions(-)
 copy inlong-manager/{manager-common/src/main/java/org/apache/inlong/manager/common/pojo/sink/kafka/KafkaSinkRequest.java => manager-client/src/main/java/org/apache/inlong/manager/client/api/sink/KafkaSink.java} (53%)