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
