IP属地:重庆
LinkedBlockingQueue 是很优秀的阻塞队列实现,某些资料显示可以达到50w QPS左右,其读写使用两把锁,但底层使用Reentr...
1.导包 2.Kafka配置类 3.配置文件(application.properties) 3.定义Consumer类 4.定义kafka-t...
声明:本文为方便日后部分DSL结构速查,由于索引设计不同,语法会有差异,本文默认String 保存为keyword类型,详细了解移步Elasti...
使用示例 结果
1.实现BatchErrorHandler 2.注册进KafkaListenerContainerFactory中
一个特殊需求,需要数据库实体对象转换成json的时候,key为数据库原表字段,value Date 转String,找了找博客,看了看fastj...
包含*字符的自己替换
写在前面:Presto 是facebook开发的一款开源大数据OLAP引擎,基于内存计算和作业分发,直接使用sql分析,不需要数据预处理,类似于...
1.pom中映入starter 2.启动类