canal 部署数据到ES 出现数据丢失

watch org.elasticsearch.client.RestHighLevelClient bulk '{params, returnObj, throwExp}' -x 5 -n 100000

使用工具观察这个方法
method=org.elasticsearch.client.RestHighLevelClient.bulk location=AtExit
ts=2025-03-26 14:49:17.506; [cost=13.149003ms] result=@ArrayList[
@Object[][
@BulkRequest[
REQUEST_OVERHEAD=@Integer[50],
requests=@ArrayList[
@UpdateRequest[update {[
@IndexRequest[index {
........
indices=@HashSet[
@String[transaction_detail],
],
timeout=@TimeValue[
NSEC_PER_MSEC=@Long[1000000],
MINUS_ONE=@TimeValue[-1],
ZERO=@TimeValue[0s],
C0=@Long[1],
C1=@Long[1000],
C2=@Long[1000000],
C3=@Long[1000000000],
C4=@Long[60000000000],
C5=@Long[3600000000000],
C6=@Long[86400000000000],
duration=@Long[1],
timeUnit=@[MINUTES],
],
waitForActiveShards=@ActiveShardCount[
ACTIVE_SHARD_COUNT_DEFAULT=@Integer[-2],
ALL_ACTIVE_SHARDS=@Integer[-1],
DEFAULT=@ActiveShardCount[DEFAULT],
ALL=@ActiveShardCount[ALL],
NONE=@ActiveShardCount[0],
ONE=@ActiveShardCount[1],
value=@Integer[-2],
$assertionsDisabled=@Boolean[true],
],
refreshPolicy=@RefreshPolicy[
NONE=@RefreshPolicy[NONE],
IMMEDIATE=@RefreshPolicy[IMMEDIATE],
WAIT_UNTIL=@RefreshPolicy[WAIT_UNTIL],
value=@String[false],
$VALUES=@RefreshPolicy[][isEmpty=false;size=3],
name=@String[NONE],
ordinal=@Integer[0],
],
globalPipeline=null,
globalRouting=null,
globalIndex=null,
globalType=null,
sizeInBytes=@Long[18550],
parentTaskId=@TaskId[
EMPTY_TASK_ID=@TaskId[unset],
nodeId=@String[],
id=@Long[-1],
],
remoteAddress=null,
],
@RequestOptions[
DEFAULT=@RequestOptions[
DEFAULT=@RequestOptions[RequestOptions{}],
headers=@UnmodifiableRandomAccessList[isEmpty=true;size=0],
httpAsyncResponseConsumerFactory=@HeapBufferedResponseConsumerFactory[org.elasticsearch.client.HttpAsyncResponseConsumerFactory$HeapBufferedResponseConsumerFactory@17d49616],
warningsHandler=null,
],
headers=@UnmodifiableRandomAccessList[isEmpty=true;size=0],
httpAsyncResponseConsumerFactory=@HeapBufferedResponseConsumerFactory[
DEFAULT_BUFFER_LIMIT=@Integer[104857600],
bufferLimit=@Integer[104857600],
],
warningsHandler=null,
],
],
@BulkResponse[
ITEMS=@String[items],
ERRORS=@String[errors],
TOOK=@String[took],
INGEST_TOOK=@String[ingest_took],
NO_INGEST_TOOK=@Long[-1],
responses=@BulkItemResponse[][
@BulkItemResponse[
发现问题：

1. requests 请求带的是全的数据，返回的BulkResponse会出现数据丢失。比如请求20个，返回10个；丢失的10个ES 也没有
   2.会出现requests10个，返回20个的情况

目前线上存在大批量数据丢失情况，帮忙解答下原因，是不是client-adapter.es7x-1.1.5-jar-with-dependencies.jar 有BUG