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 27d577702c [INLONG-10008][Dashboard][Manager] Supplement fields of
MongoDB data source for Dashboard (#10009)
add fbf1ffcb69 [INLONG-9960][Manager] Support to config kafka data node
(#10005)
No new revisions were added by this update.
Summary of changes:
.../inlong/manager/common/enums/ErrorCodeEnum.java | 1 +
.../pojo/cluster/kafka/KafkaClusterInfo.java | 6 ++
.../pojo/cluster/kafka/KafkaClusterRequest.java | 6 ++
.../manager/pojo/node/cls/ClsDataNodeInfo.java | 2 +-
.../KafkaDataNodeDTO.java} | 40 ++++++-------
.../KafkaDataNodeInfo.java} | 35 +++++++-----
.../KafkaDataNodeRequest.java} | 29 ++++++----
.../KafkaDataNodeOperator.java} | 66 +++++++++++-----------
.../service/resource/queue/kafka/KafkaUtils.java | 2 +-
9 files changed, 105 insertions(+), 82 deletions(-)
copy
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/{pulsar/PulsarDataNodeDTO.java
=> kafka/KafkaDataNodeDTO.java} (63%)
copy
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/{mysql/MySQLDataNodeInfo.java
=> kafka/KafkaDataNodeInfo.java} (64%)
copy
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/{iceberg/IcebergDataNodeRequest.java
=> kafka/KafkaDataNodeRequest.java} (66%)
copy
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/node/{pulsar/PulsarDataNodeOperator.java
=> kafka/KafkaDataNodeOperator.java} (58%)
