使用kafak的消费者多线程插入批量插入elasticsearch,发现插入几千个数据后,后面数据就无法插入了。检测kafka是正常消费的,没法找到原因。
使用代码:
bulk.add(client.prepareIndex(index, type, id).setSource(readValue,XContentType.JSON));
BulkResponse response = bulk.get();
使用response.hasFailures没有发现错误,但是数据就是无法插入,后台也没有任何的报错
使用代码:
bulk.add(client.prepareIndex(index, type, id).setSource(readValue,XContentType.JSON));
BulkResponse response = bulk.get();
使用response.hasFailures没有发现错误,但是数据就是无法插入,后台也没有任何的报错
1 个回复
elasticsearch9 - 90后IT男
赞同来自: