【任务提交】
规则引擎从 kafka 队列消费到数据后,会按照不同的提交策略和处理策略将消息输入进规则链[传入RuleEngineActor顶层Actor],RuleEngineActor在执行完传递后会调用成功或失败,然后再执行下一条、下一批的输入:
【日志分析】
提交时获取提交策略:
//TbRuleEngineQueueConfiguration(
// name=Main,
// topic=tb_rule_engine.main,
// pollInterval=25,
// partitions=10,