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 c6fd02418 [INLONG-6291][CVE] Update ini4j to fix the CVE-2022-41404
(#6292)
add 537f59962 [INLONG-4986][Agent] Support MQTT Source (#6245)
No new revisions were added by this update.
Summary of changes:
.../apache/inlong/agent/pojo/JobProfileDto.java | 31 +++
.../pojo/{DbCollectorTask.java => MqttJob.java} | 46 ++--
inlong-agent/agent-plugins/pom.xml | 5 +
.../{SQLServerSource.java => MqttSource.java} | 40 +--
.../agent/plugin/sources/reader/MqttReader.java | 238 ++++++++++++++++++
.../agent/plugin/sources/TestMqttConnect.java | 74 ++++++
.../agent/plugin/sources/TestMqttReader.java | 188 ++++++++++++++
...estSQLServerSource.java => TestMqttSource.java} | 20 +-
.../apache/inlong/common/enums/TaskTypeEnum.java | 4 +-
licenses/inlong-agent/LICENSE | 1 +
.../licenses/LICENSE-paho.mqtt.java.txt} | 273 +--------------------
pom.xml | 1 +
12 files changed, 603 insertions(+), 318 deletions(-)
copy
inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/pojo/{DbCollectorTask.java
=> MqttJob.java} (51%)
copy
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/{SQLServerSource.java
=> MqttSource.java} (61%)
create mode 100644
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/reader/MqttReader.java
create mode 100644
inlong-agent/agent-plugins/src/test/java/org/apache/inlong/agent/plugin/sources/TestMqttConnect.java
create mode 100644
inlong-agent/agent-plugins/src/test/java/org/apache/inlong/agent/plugin/sources/TestMqttReader.java
copy
inlong-agent/agent-plugins/src/test/java/org/apache/inlong/agent/plugin/sources/{TestSQLServerSource.java
=> TestMqttSource.java} (85%)
copy licenses/{inlong-sort-connectors/licenses/LICENSE-connect-runtime.txt =>
inlong-agent/licenses/LICENSE-paho.mqtt.java.txt} (50%)
