我有点怀疑你在刷屏

elasticsearch5.50 无法使用java bulk插入数据

Elasticsearch | 作者 elasticsearch9 | 发布于2017年10月25日 | 阅读数:2121

使用kafak的消费者多线程插入批量插入elasticsearch,发现插入几千个数据后,后面数据就无法插入了。检测kafka是正常消费的,没法找到原因。
使用代码:

bulk.add(client.prepareIndex(index, type, id).setSource(readValue,XContentType.JSON));
BulkResponse response = bulk.get();
使用response.hasFailures没有发现错误,但是数据就是无法插入,后台也没有任何的报错
已邀请:

elasticsearch9 - 90后IT男

赞同来自:

没有找到错误原因,但是我使用的elasticsearch 中的bulkProcessor进行批量的增删改,没有出现数据丢失和阻塞情况。

要回复问题请先登录注册