Esper v7.1.0启用入站线程池时出现数据丢失问题
Esper 7.1.0 启用入站线程池时的数据丢失问题
我在使用Esper 7.1.0版本开发时,碰到了一个棘手的问题:当开启入站线程池(ThreadPoolInbound)配置后,会出现数据丢失的异常行为。
下面是能复现这个问题的极简代码示例:
Configuration config = new Configuration(); // 开启并发处理的入站线程池 config.getEngineDefaults().getThreading().setThreadPoolInbound(true); EPServiceProvider epService = EPServiceProviderManager.getDefaultProvider(config); // 定义一个简单的对象数组事件模式 epService.getEPAdministrator().createEPL("create objectarray schema LogLine as (account_name string, value int)");
补充说明:在后续的事件发送与业务处理环节中(示例代码省略了事件推送部分),启用入站线程池后会出现部分LogLine事件无法被引擎正确接收或处理,最终导致数据丢失。
内容的提问来源于stack exchange,提问作者Taras
相关产品推荐
相关产品推荐

