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