加载中
kafka指定时间、topic进行消费数据 (kafka 学习【二】)

指定时间和topic进行数据回溯 @Resource private KafkaConsumer<String,String> kafkaConsumer; /** * 指定时间和topic进行消费数据 * @param request * @throws Exception */ public void ...

2023/10/09 14:07
31
关于捕获异步线程异常

关于Async注解异步异常捕获 @Async public void test(Event event) { int result= 1/0; } @Configuration public class AsyncExceptionConfig implements AsyncConfigurer { privat......

2022/02/24 19:52
213
记录OOM GC问题

首先排查TOP 查看哪个进程占用CPU比例高 执行 jstack java 4372(进程号) >> cpu.txt ,将进程线程使用情况输出到文件内 执行top -H -p 4372 查看线程4377 将其转成16进制 为1119,到刚才 js...

rabbitmq 之 ack

场景1:对于消息处理失败,有可能有由于网络波动导致的数据处理异常,待网络稳定时消息就会正常处理,对于这种处理失败,应该继续尝试去处理消息 场景2:消息重复处理,例如我们通过消息队列...

2019/01/14 21:41
155
Mysql 事务原理简单分析

Mysql Innodb中的事务隔离级别 隔离级别 脏读(Dirty Read) 不可重复读(NonRepeatable Read) 幻读(Phantom Read) 未提交读(Read uncommitted) 可能 可能 可能 已提交读(Read commit...

2019/01/13 22:26
3.1K
rabbitmq利用死信队列+TTL 实现延迟队列

适用场景:订单超时未支付,倘若适用定时器的话,那么数据量大的话,轮询查询数据,首先IO开销大,其次任务时间要求高,扫描越频繁性能可能就越低。 延迟队列顾名思义延迟消费数据,那么先解...

2019/01/09 11:24
789

没有更多内容

加载失败,请刷新页面

返回顶部
顶部