You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@inlong.apache.org by al...@apache.org on 2022/01/20 08:02:05 UTC

[incubator-inlong] branch master updated (892c4fc -> be83d3d)

This is an automated email from the ASF dual-hosted git repository.

aloyszhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git.


    from 892c4fc  audit SDK support real-time report (#2223)
     add be83d3d  fix one message will put tow channel, and store two message (#2206)

No new revisions were added by this update.

Summary of changes:
 .../inlong/audit/consts/ConfigConstants.java       |   2 +
 .../audit/channel/FailoverChannelProcessor.java    | 299 +++++++++++++++++++++
 .../org/apache/inlong/audit/sink/PulsarSink.java   |   3 +-
 .../inlong/audit/source/SimpleTcpSource.java       |  15 ++
 4 files changed, 317 insertions(+), 2 deletions(-)
 create mode 100644 inlong-audit/audit-source/src/main/java/org/apache/inlong/audit/channel/FailoverChannelProcessor.java