Is it by design that EventTargetTrigger is having at-most-once QoS?
|
try { |
|
sinkTask.put(triggerRecords); |
|
offsetManager.commit(triggerRecords); |
|
} catch (Exception exception) { |
|
logger.error(getServiceName() + " push target exception, stackTrace-", exception); |
|
triggerRecords.forEach(triggerRecord -> errorHandler.handle(triggerRecord, exception)); |
|
} |
Is it by design that EventTargetTrigger is having at-most-once QoS?
rocketmq-eventbridge/adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventTargetTrigger.java
Lines 76 to 82 in 1ea27ef