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/11/28 07:00:22 UTC
[inlong] branch master updated (6a6315142 -> 30e17af88)
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/inlong.git
from 6a6315142 [INLONG-6638][TubeMQ] C++ client supports filtering consume with the "-" character (#6644)
add 30e17af88 [INLONG-6620][Sort] Support metadata for Kafka source (#6622)
No new revisions were added by this update.
Summary of changes:
.../org/apache/inlong/common/enums/MetaField.java | 37 ++++++++++++-
.../org/apache/inlong/sort/protocol/Metadata.java | 9 ++++
.../protocol/node/extract/KafkaExtractNode.java | 38 +++++++++++++-
.../node/extract/KafkaExtractNodeTest.java | 8 +++
.../sort/kafka/table/KafkaDynamicSource.java | 60 ++++++++++++++++++++++
.../table/UpsertKafkaDynamicTableFactory.java | 3 +-
6 files changed, 150 insertions(+), 5 deletions(-)