This is an automated email from the ASF dual-hosted git repository.
zirui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git.
from e33c9ed [INLONG-3291][DataProxy] Add default channel to fix the order
message does not work (#3292)
add ba6d871 [INLONG-3274][Agent] Change the task status to failed when
the Kafka topic was deleted
No new revisions were added by this update.
Summary of changes:
.../org/apache/inlong/agent/plugin/Reader.java | 6 ++++++
.../apache/inlong/agent/core/task/TaskWrapper.java | 25 +++++++++++++++++-----
.../apache/inlong/agent/task/TestTaskWrapper.java | 9 ++++++--
.../inlong/agent/plugin/sources/KafkaSource.java | 10 ++++++---
.../agent/plugin/sources/reader/BinlogReader.java | 5 +++++
.../agent/plugin/sources/reader/KafkaReader.java | 14 +++++++++++-
.../agent/plugin/sources/reader/SqlReader.java | 5 +++++
.../plugin/sources/reader/TextFileReader.java | 5 +++++
.../agent/plugin/sources/TestKafkaReader.java | 2 +-
9 files changed, 69 insertions(+), 12 deletions(-)
