This is an automated email from the ASF dual-hosted git repository.
gosonzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from 6f506f1f7 [INLONG-6375][Dashboard] Cluster supports new Kafka type
(#6378)
add e97a2c269 [INLONG-6369][DataProxy] Use the defined message attribute
Key value in InLong-Common (#6386)
No new revisions were added by this update.
Summary of changes:
.../inlong/common/msg/AttributeConstants.java | 26 +++++--
.../org/apache/inlong/common/msg/InLongMsg.java | 2 +-
.../apache/inlong/dataproxy/base/ProxyMessage.java | 3 +-
.../dataproxy/channel/FailoverChannelSelector.java | 2 +-
.../inlong/dataproxy/config/ConfigHolder.java | 6 +-
.../inlong/dataproxy/config/ConfigManager.java | 4 +-
.../config/holder/MQClusterConfigHolder.java | 4 +-
.../inlong/dataproxy/consts/AttrConstants.java | 31 ++++----
.../dataproxy/consts/AttributeConstants.java | 91 ----------------------
.../inlong/dataproxy/dispatch/DispatchManager.java | 2 +-
.../inlong/dataproxy/http/MessageFilter.java | 5 +-
.../dataproxy/http/MessageProcessServlet.java | 9 ++-
.../dataproxy/http/SimpleMessageHandler.java | 15 ++--
.../dataproxy/metrics/DataProxyMetricItem.java | 2 +-
.../dataproxy/metrics/DataProxyMetricItemSet.java | 2 +-
.../inlong/dataproxy/metrics/audit/AuditUtils.java | 2 +-
.../apache/inlong/dataproxy/sink/PulsarSink.java | 4 +-
.../org/apache/inlong/dataproxy/sink/TubeSink.java | 4 +-
.../inlong/dataproxy/sink/common/TubeUtils.java | 2 +-
.../dataproxy/sink/pulsar/PulsarClientService.java | 2 +-
.../inlong/dataproxy/sink/pulsar/SinkTask.java | 2 +-
.../dataproxy/source/DefaultServiceDecoder.java | 11 +--
.../dataproxy/source/ServerMessageHandler.java | 45 +++++------
.../dataproxy/source/SimpleMessageHandler.java | 26 ++++---
.../inlong/dataproxy/utils/MessageUtils.java | 30 ++++---
.../sdk/dataproxy/pb/metrics/SdkMetricItem.java | 2 +-
.../sort/standalone/metrics/SortMetricItem.java | 2 +-
27 files changed, 127 insertions(+), 209 deletions(-)
copy
inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/plugin/Channel.java
=>
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/consts/AttrConstants.java
(55%)
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/consts/AttributeConstants.java
