由 log4j2日志发送到Elasticsearch引起的缓冲池的实现
在看Elasticsearch的时候想到最近的一个问题,log4j日志先发到kafka,再由logstash从kafka输出到Elasticsearch中,能否直接将log4j日志发送到Elasticsearch(只是单纯想看看怎么直接操作Elasticsearch,肯定是先发到kakfa的方案更靠谱)
找到如下项目,utility-log4j2-elasticsearch,只在bitbucket上有,github上啥的都没有,一定要看3.0的,前几个版本看的有点晕菜,代码太长了500+,就不贴出来了
https://bitbucket.org/inemar/...
主要涉及的内容为日志发送到一个缓冲池中,本地另起一个线程去消费缓冲池中的内容,代码写的很多有值得借鉴的地方
还有一些不明白的,如果正好有同学感兴趣,在看并且能解答下面的几个问题的,请不惜赐教
代码283行 每次都生成了一个client,要怎么改造成一个连接池的形式
相关推荐
newbornzhao 2020-09-14
做对一件事很重要 2020-09-07
renjinlong 2020-09-03
明瞳 2020-08-19
李玉志 2020-08-19
mengyue 2020-08-07
molong0 2020-08-06
AFei00 2020-08-03
molong0 2020-08-03
wenwentana 2020-08-03
YYDU 2020-08-03
另外一部分,则需要先做聚类、分类处理,将聚合出的分类结果存入ES集群的聚类索引中。数据处理层的聚合结果存入ES中的指定索引,同时将每个聚合主题相关的数据存入每个document下面的某个field下。
sifeimeng 2020-08-03
心丨悦 2020-08-03
liangwenrong 2020-07-31
sifeimeng 2020-08-01
mengyue 2020-07-30
tigercn 2020-07-29
IceStreamLab 2020-07-29